feat(QueueScheduler): rename ImmediateScheduler to QueueScheduler

- rename ImmediateScheduler to QueueScheduler
- rename ImmediateAction to QueueAction
- rename Rx.Scheduler.immediate to Rx.Scheduler.queue

BREAKING CHANGE: Immediate scheduler is now Queue scheduler
related #838

spec/observables/IteratorObservable-spec.js

@@ -88,7 +88,7 @@ describe('IteratorObservable', function () {
       [10, 20, 30, 40],
       function (x) { return x; },
       null,
-      Rx.Scheduler.immediate
+      Rx.Scheduler.queue
     );
 
     var subscriber = Rx.Subscriber.create(

spec/observables/combineLatest-spec.js

@@ -1,7 +1,7 @@
 /* globals describe, it, expect, hot, cold, expectObservable, expectSubscriptions */
 var Rx = require('../../dist/cjs/Rx');
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('Observable.combineLatest', function () {
   it('should combineLatest the provided observables', function () {
@@ -17,11 +17,11 @@ describe('Observable.combineLatest', function () {
   });
 
   it('should combine an immediately-scheduled source with an immediately-scheduled second', function (done) {
-    var a = Observable.of(1, 2, 3, immediateScheduler);
-    var b = Observable.of(4, 5, 6, 7, 8, immediateScheduler);
+    var a = Observable.of(1, 2, 3, queueScheduler);
+    var b = Observable.of(4, 5, 6, 7, 8, queueScheduler);
     var r = [[1, 4], [2, 4], [2, 5], [3, 5], [3, 6], [3, 7], [3, 8]];
     var i = 0;
-    Observable.combineLatest(a, b, immediateScheduler).subscribe(function (vals) {
+    Observable.combineLatest(a, b, queueScheduler).subscribe(function (vals) {
       expect(vals).toDeepEqual(r[i++]);
     }, null, function () {
       expect(i).toEqual(r.length);

spec/observables/concat-spec.js

@@ -1,7 +1,7 @@
 /* globals describe, it, expect, expectObservable, expectSubscriptions, cold */
 var Rx = require('../../dist/cjs/Rx');
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('Observable.concat', function () {
   it('should emit elements from multiple sources', function () {
@@ -315,12 +315,12 @@ describe('Observable.concat', function () {
   });
 
   it('should concat an immediately-scheduled source with an immediately-scheduled second', function (done) {
-    var a = Observable.of(1, 2, 3, immediateScheduler);
-    var b = Observable.of(4, 5, 6, 7, 8, immediateScheduler);
+    var a = Observable.of(1, 2, 3, queueScheduler);
+    var b = Observable.of(4, 5, 6, 7, 8, queueScheduler);
     var r = [1, 2, 3, 4, 5, 6, 7, 8];
     var i = 0;
 
-    Observable.concat(a, b, immediateScheduler).subscribe(function (vals) {
+    Observable.concat(a, b, queueScheduler).subscribe(function (vals) {
       expect(vals).toBe(r[i++]);
     }, null, done);
   });

spec/observables/interval-spec.js

@@ -1,7 +1,6 @@
 /* globals describe, it, expect, spyOn */
 var Rx = require('../../dist/cjs/Rx');
 var Observable = Rx.Observable;
-var immediate = Rx.Scheduler.immediate;
 var Observer = Rx.Observer;
 
 describe('Observable.interval', function () {

spec/observables/of-spec.js

@@ -26,7 +26,7 @@ describe('Observable.of', function () {
   });
 
   it('should return a scalar observable if only passed one value and a scheduler', function () {
-    var obs = Observable.of('one', Rx.Scheduler.immediate);
+    var obs = Observable.of('one', Rx.Scheduler.queue);
     expect(obs instanceof ScalarObservable).toBe(true);
   });
 
@@ -41,7 +41,7 @@ describe('Observable.of', function () {
   });
 
   it('should return an empty observable if passed only a scheduler', function () {
-    var obs = Observable.of(Rx.Scheduler.immediate);
+    var obs = Observable.of(Rx.Scheduler.queue);
     expect(obs instanceof EmptyObservable).toBe(true);
   });
 

spec/observables/timer-spec.js

@@ -1,7 +1,6 @@
 /* globals describe, it, expect, expectObservable, hot, rxTestScheduler */
 var Rx = require('../../dist/cjs/Rx');
 var Observable = Rx.Observable;
-var immediate = Rx.Scheduler.immediate;
 var Observer = Rx.Observer;
 
 describe('Observable.timer', function () {

spec/observables/zip-spec.js

@@ -1,7 +1,7 @@
 /* globals describe, it, expect, expectObservable, expectSubscriptions, hot, cold, Symbol */
 var Rx = require('../../dist/cjs/Rx');
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('Observable.zip', function () {
   it('should combine a source with a second', function () {
@@ -562,8 +562,8 @@ describe('Observable.zip', function () {
   });
 
   it('should combine an immediately-scheduled source with an immediately-scheduled second', function (done) {
-    var a = Observable.of(1, 2, 3, immediateScheduler);
-    var b = Observable.of(4, 5, 6, 7, 8, immediateScheduler);
+    var a = Observable.of(1, 2, 3, queueScheduler);
+    var b = Observable.of(4, 5, 6, 7, 8, queueScheduler);
     var r = [[1, 4], [2, 5], [3, 6]];
     var i = 0;
 

spec/operators/combineAll-spec.js

@@ -1,7 +1,7 @@
 /* globals describe, it, expect, hot, cold, expectObservable */
 var Rx = require('../../dist/cjs/Rx');
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('Observable.prototype.combineAll()', function () {
   it('should work with two nevers', function () {
@@ -412,11 +412,11 @@ describe('Observable.prototype.combineAll()', function () {
   });
 
   it('should combine two immediately-scheduled observables', function (done) {
-    var a = Observable.of(1, 2, 3, immediateScheduler);
-    var b = Observable.of(4, 5, 6, 7, 8, immediateScheduler);
+    var a = Observable.of(1, 2, 3, queueScheduler);
+    var b = Observable.of(4, 5, 6, 7, 8, queueScheduler);
     var r = [[1, 4], [2, 4], [2, 5], [3, 5], [3, 6], [3, 7], [3, 8]];
     var i = 0;
-    Observable.of(a, b, immediateScheduler).combineAll().subscribe(function (vals) {
+    Observable.of(a, b, queueScheduler).combineAll().subscribe(function (vals) {
       expect(vals).toDeepEqual(r[i++]);
     }, null, function () {
       expect(i).toEqual(r.length);

spec/operators/combineLatest-spec.js

@@ -1,7 +1,7 @@
 /* globals describe, it, expect, hot, cold, expectObservable, expectSubscriptions */
 var Rx = require('../../dist/cjs/Rx');
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('Observable.prototype.combineLatest', function () {
   it('should work with two nevers', function () {

spec/operators/merge-spec.js

@@ -1,7 +1,7 @@
 /* globals describe, it, expect, hot, cold, expectObservable, expectSubscriptions, rxTestScheduler */
 var Rx = require('../../dist/cjs/Rx');
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('Observable.prototype.merge', function () {
   it('should merge a source with a second', function (done) {
@@ -15,11 +15,11 @@ describe('Observable.prototype.merge', function () {
   });
 
   it('should merge an immediately-scheduled source with an immediately-scheduled second', function (done) {
-    var a = Observable.of(1, 2, 3, immediateScheduler);
-    var b = Observable.of(4, 5, 6, 7, 8, immediateScheduler);
+    var a = Observable.of(1, 2, 3, queueScheduler);
+    var b = Observable.of(4, 5, 6, 7, 8, queueScheduler);
     var r = [1, 2, 4, 3, 5, 6, 7, 8];
     var i = 0;
-    a.merge(b, immediateScheduler).subscribe(function (val) {
+    a.merge(b, queueScheduler).subscribe(function (val) {
       expect(val).toBe(r[i++]);
     }, null, done);
   });
@@ -258,11 +258,11 @@ describe('Observable.prototype.mergeAll', function () {
   });
 
   it('should merge two immediately-scheduled observables', function (done) {
-    var a = Observable.of(1, 2, 3, immediateScheduler);
-    var b = Observable.of(4, 5, 6, 7, 8, immediateScheduler);
+    var a = Observable.of(1, 2, 3, queueScheduler);
+    var b = Observable.of(4, 5, 6, 7, 8, queueScheduler);
     var r = [1, 2, 4, 3, 5, 6, 7, 8];
     var i = 0;
-    Observable.of(a, b, immediateScheduler).mergeAll().subscribe(function (val) {
+    Observable.of(a, b, queueScheduler).mergeAll().subscribe(function (val) {
       expect(val).toBe(r[i++]);
     }, null, done);
   });

spec/operators/switch-spec.js

@@ -3,7 +3,7 @@ var Rx = require('../../dist/cjs/Rx');
 var Promise = require('promise');
 
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('Observable.prototype.switch()', function () {
   it.asDiagram('switch')('should switch a hot observable of cold observables', function () {
@@ -16,11 +16,11 @@ describe('Observable.prototype.switch()', function () {
   });
 
   it('should switch to each immediately-scheduled inner Observable', function (done) {
-    var a = Observable.of(1, 2, 3, immediateScheduler);
-    var b = Observable.of(4, 5, 6, immediateScheduler);
+    var a = Observable.of(1, 2, 3, queueScheduler);
+    var b = Observable.of(4, 5, 6, queueScheduler);
     var r = [1, 4, 5, 6];
     var i = 0;
-    Observable.of(a, b, immediateScheduler)
+    Observable.of(a, b, queueScheduler)
       .switch()
       .subscribe(function (x) {
         expect(x).toBe(r[i++]);

spec/operators/switchFirst-spec.js

@@ -3,7 +3,7 @@ var Rx = require('../../dist/cjs/Rx');
 var Promise = require('promise');
 
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('Observable.prototype.switchFirst()', function () {
   it('should switch to first immediately-scheduled inner Observable', function () {

spec/operators/switchMap-spec.js

@@ -1,7 +1,7 @@
 /* globals describe, it, expect, hot, cold, expectObservable, expectSubscriptions */
 var Rx = require('../../dist/cjs/Rx');
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('Observable.prototype.switchMap()', function () {
   it('should switch with a selector function', function (done) {

spec/operators/switchMapFirst-spec.js

@@ -3,7 +3,7 @@ var Rx = require('../../dist/cjs/Rx');
 var Promise = require('promise');
 
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('Observable.prototype.switchMapFirst()', function () {
   it('should handle outer throw', function () {

spec/operators/switchMapTo-spec.js

@@ -1,7 +1,7 @@
 /* globals describe, it, expect, cold, hot, expectObservable, expectSubscriptions */
 var Rx = require('../../dist/cjs/Rx');
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('Observable.prototype.switchMapTo()', function () {
   it('should switch a synchronous many outer to a synchronous many inner', function (done) {

spec/operators/zip-spec.js

@@ -1,7 +1,7 @@
 /* globals describe, it, expect, expectObservable, expectSubscriptions, hot, cold */
 var Rx = require('../../dist/cjs/Rx');
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('zip', function () {
   it('should combine a source with a second', function () {
@@ -561,8 +561,8 @@ describe('zip', function () {
   });
 
   it('should combine an immediately-scheduled source with an immediately-scheduled second', function (done) {
-    var a = Observable.of(1, 2, 3, immediateScheduler);
-    var b = Observable.of(4, 5, 6, 7, 8, immediateScheduler);
+    var a = Observable.of(1, 2, 3, queueScheduler);
+    var b = Observable.of(4, 5, 6, 7, 8, queueScheduler);
     var r = [[1, 4], [2, 5], [3, 6]];
     var i = 0;
 

spec/operators/zipAll-spec.js

@@ -1,7 +1,7 @@
 /* globals describe, it, expect, expectSubscriptions, expectObservable */
 var Rx = require('../../dist/cjs/Rx');
 var Observable = Rx.Observable;
-var immediateScheduler = Rx.Scheduler.immediate;
+var queueScheduler = Rx.Scheduler.queue;
 
 describe('Observable.prototype.zipAll', function () {
   it('should combine two observables', function () {
@@ -654,25 +654,25 @@ describe('Observable.prototype.zipAll', function () {
   });
 
   it('should combine two immediately-scheduled observables', function (done) {
-    var a = Observable.of(1, 2, 3, immediateScheduler);
-    var b = Observable.of(4, 5, 6, 7, 8, immediateScheduler);
+    var a = Observable.of(1, 2, 3, queueScheduler);
+    var b = Observable.of(4, 5, 6, 7, 8, queueScheduler);
     var r = [[1, 4], [2, 5], [3, 6]];
     var i = 0;
 
-    var result = Observable.of(a, b, immediateScheduler).zipAll();
+    var result = Observable.of(a, b, queueScheduler).zipAll();
 
     result.subscribe(function (vals) {
       expect(vals).toDeepEqual(r[i++]);
     }, null, done);
   });
 
   it('should combine a source with an immediately-scheduled source', function (done) {
-    var a = Observable.of(1, 2, 3, immediateScheduler);
+    var a = Observable.of(1, 2, 3, queueScheduler);
     var b = Observable.of(4, 5, 6, 7, 8);
     var r = [[1, 4], [2, 5], [3, 6]];
     var i = 0;
 
-    var result = Observable.of(a, b, immediateScheduler).zipAll();
+    var result = Observable.of(a, b, queueScheduler).zipAll();
 
     result.subscribe(function (vals) {
       expect(vals).toDeepEqual(r[i++]);

spec/scheduler-spec.js

@@ -3,14 +3,14 @@ var Rx = require('../dist/cjs/Rx');
 
 var Scheduler = Rx.Scheduler;
 
-describe('Scheduler.immediate', function () {
+describe('Scheduler.queue', function () {
   it('should schedule things recursively', function () {
     var call1 = false;
     var call2 = false;
-    Scheduler.immediate.active = false;
-    Scheduler.immediate.schedule(function () {
+    Scheduler.queue.active = false;
+    Scheduler.queue.schedule(function () {
       call1 = true;
-      Scheduler.immediate.schedule(function () {
+      Scheduler.queue.schedule(function () {
         call2 = true;
       });
     });
@@ -20,7 +20,7 @@ describe('Scheduler.immediate', function () {
 
   it('should schedule things in the future too', function (done) {
     var called = false;
-    Scheduler.immediate.schedule(function () {
+    Scheduler.queue.schedule(function () {
       called = true;
     }, 50);
 

src/Rx.KitchenSink.ts

@@ -140,9 +140,9 @@ import {EmptyError} from './util/EmptyError';
 import {ObjectUnsubscribedError} from './util/ObjectUnsubscribedError';
 import {ArgumentOutOfRangeError} from './util/ArgumentOutOfRangeError';
 import {nextTick} from './scheduler/nextTick';
-import {immediate} from './scheduler/immediate';
+import {queue} from './scheduler/queue';
 import {NextTickScheduler} from './scheduler/NextTickScheduler';
-import {ImmediateScheduler} from './scheduler/ImmediateScheduler';
+import {QueueScheduler} from './scheduler/QueueScheduler';
 import {TimeInterval} from './operator/extended/timeInterval';
 import {TestScheduler} from './testing/TestScheduler';
 import {VirtualTimeScheduler} from './scheduler/VirtualTimeScheduler';
@@ -152,7 +152,7 @@ import {rxSubscriber} from './symbol/rxSubscriber';
 /* tslint:disable:no-var-keyword */
 var Scheduler = {
   nextTick,
-  immediate
+  queue
 };
 
 var Symbol = {

src/Rx.ts

@@ -118,17 +118,17 @@ import {Notification} from './Notification';
 import {EmptyError} from './util/EmptyError';
 import {ArgumentOutOfRangeError} from './util/ArgumentOutOfRangeError';
 import {ObjectUnsubscribedError} from './util/ObjectUnsubscribedError';
-import {immediate} from './scheduler/immediate';
+import {queue} from './scheduler/queue';
 import {nextTick} from './scheduler/nextTick';
 import {NextTickScheduler} from './scheduler/NextTickScheduler';
-import {ImmediateScheduler} from './scheduler/ImmediateScheduler';
+import {QueueScheduler} from './scheduler/QueueScheduler';
 import {rxSubscriber} from './symbol/rxSubscriber';
 /* tslint:enable:no-unused-variable */
 
 /* tslint:disable:no-var-keyword */
 var Scheduler = {
   nextTick,
-  immediate
+  queue
 };
 
 var Symbol = {