fix(AnonymousSubject): allow anonymous observers as destination

ReactiveX · May 22, 2016 · 0e2c28b · 0e2c28b
1 parent 55d5141
commit 0e2c28b
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/src/Subject.ts b/src/Subject.ts
@@ -115,15 +115,24 @@ export class AnonymousSubject<T> extends Subject<T> {
   }
 
   next(value: T) {
-    this.destination.next(value);
+    const { destination } = this;
+    if (destination && destination.next) {
+      destination.next(value);
+    }
   }
 
   error(err: any) {
-    this.destination.error(err);
+    const { destination } = this;
+    if (destination && destination.error) {
+      this.destination.error(err);
+    }
   }
 
   complete() {
-    this.destination.complete();
+    const { destination } = this;
+    if (destination && destination.complete) {
+      this.destination.complete();
+    }
   }
 
   _subscribe(subscriber: Subscriber<T>): Subscription {