fix(ScalarObservable): set _isScalar to false when initialized with a…

… scheduler
ReactiveX · May 2, 2016 · 5037b3a · 5037b3a
1 parent f5090b4
commit 5037b3a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/observable/ScalarObservable.ts b/src/observable/ScalarObservable.ts
@@ -34,6 +34,9 @@ export class ScalarObservable<T> extends Observable<T> {
 
   constructor(public value: T, private scheduler?: Scheduler) {
     super();
+    if (scheduler) {
+      this._isScalar = false;
+    }
   }
 
   protected _subscribe(subscriber: Subscriber<T>): TeardownLogic {