diff --git a/perf/micro/current-thread-scheduler/observable/empty.js b/perf/micro/current-thread-scheduler/observable/empty.js
index 3db2d4e01a..1c14f05aac 100644
--- a/perf/micro/current-thread-scheduler/observable/empty.js
+++ b/perf/micro/current-thread-scheduler/observable/empty.js
@@ -3,7 +3,7 @@ var RxNew = require('../../../../index');
 
 module.exports = function empty(suite) {
   var oldEmptyWithCurrentThreadScheduler = RxOld.Observable.empty(RxOld.Scheduler.currentThread);
-  var newEmptyWithCurrentThreadScheduler = RxNew.Observable.empty(RxNew.Scheduler.immediate);
+  var newEmptyWithCurrentThreadScheduler = RxNew.Observable.empty(RxNew.Scheduler.queue);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/observable/from-with-array.js b/perf/micro/current-thread-scheduler/observable/from-with-array.js
index 056a6c30f6..5be4f2fd75 100644
--- a/perf/micro/current-thread-scheduler/observable/from-with-array.js
+++ b/perf/micro/current-thread-scheduler/observable/from-with-array.js
@@ -16,6 +16,6 @@ module.exports = function fromWithArray(suite) {
       RxOld.Observable.from(args, null, null, RxOld.Scheduler.currentThread).subscribe(_next, _error, _complete);
     })
     .add('new from (array) with current thread scheduler', function () {
-      RxNew.Observable.from(args, null, null, RxNew.Scheduler.immediate).subscribe(_next, _error, _complete);
+      RxNew.Observable.from(args, null, null, RxNew.Scheduler.queue).subscribe(_next, _error, _complete);
     });
 };
\ No newline at end of file
diff --git a/perf/micro/current-thread-scheduler/observable/from-with-string.js b/perf/micro/current-thread-scheduler/observable/from-with-string.js
index 74bdecc145..59bc10daa7 100644
--- a/perf/micro/current-thread-scheduler/observable/from-with-string.js
+++ b/perf/micro/current-thread-scheduler/observable/from-with-string.js
@@ -17,6 +17,6 @@ module.exports = function fromWithString(suite) {
       RxOld.Observable.from(argStr, null, null, RxOld.Scheduler.currentThread).subscribe(_next, _error, _complete);
     })
     .add('new from (string) with current thread scheduler', function () {
-      RxNew.Observable.from(argStr, null, null, RxNew.Scheduler.immediate).subscribe(_next, _error, _complete);
+      RxNew.Observable.from(argStr, null, null, RxNew.Scheduler.queue).subscribe(_next, _error, _complete);
     });
 };
\ No newline at end of file
diff --git a/perf/micro/current-thread-scheduler/observable/fromarray.js b/perf/micro/current-thread-scheduler/observable/fromarray.js
index 1f6998bfc6..e3c6074b8b 100644
--- a/perf/micro/current-thread-scheduler/observable/fromarray.js
+++ b/perf/micro/current-thread-scheduler/observable/fromarray.js
@@ -8,7 +8,7 @@ module.exports = function fromArray(suite) {
   }
 
   var oldFromArrayWithCurrentThreadScheduler = RxOld.Observable.fromArray(args, RxOld.Scheduler.currentThread);
-  var newFromArrayWithCurrentThreadScheduler = RxNew.Observable.fromArray(args, RxNew.Scheduler.immediate);
+  var newFromArrayWithCurrentThreadScheduler = RxNew.Observable.fromArray(args, RxNew.Scheduler.queue);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/observable/interval.js b/perf/micro/current-thread-scheduler/observable/interval.js
index bdc8cc22e3..b1904bb64f 100644
--- a/perf/micro/current-thread-scheduler/observable/interval.js
+++ b/perf/micro/current-thread-scheduler/observable/interval.js
@@ -3,7 +3,7 @@ var RxNew = require('../../../../index');
 
 module.exports = function interval(suite) {
   var oldIntervalWithCurrentThreadScheduler = RxOld.Observable.interval(25, RxOld.Scheduler.currentThread).take(5);
-  var newIntervalWithCurrentThreadScheduler = RxNew.Observable.interval(25, RxNew.Scheduler.immediate).take(5);
+  var newIntervalWithCurrentThreadScheduler = RxNew.Observable.interval(25, RxNew.Scheduler.queue).take(5);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/observable/of.js b/perf/micro/current-thread-scheduler/observable/of.js
index cd16154330..0877f2e7c4 100644
--- a/perf/micro/current-thread-scheduler/observable/of.js
+++ b/perf/micro/current-thread-scheduler/observable/of.js
@@ -8,7 +8,7 @@ module.exports = function of(suite) {
   }
 
   var oldOfWithCurrentThreadScheduler = RxOld.Observable.of.apply(null, args.concat(RxOld.Scheduler.currentThread));
-  var newOfWithCurrentThreadScheduler = RxNew.Observable.of.apply(null, args.concat(RxNew.Scheduler.immediate));
+  var newOfWithCurrentThreadScheduler = RxNew.Observable.of.apply(null, args.concat(RxNew.Scheduler.queue));
 
   // add tests
   function _next(x) { }
diff --git a/perf/micro/current-thread-scheduler/observable/range.js b/perf/micro/current-thread-scheduler/observable/range.js
index 84e07d32c0..1717867766 100644
--- a/perf/micro/current-thread-scheduler/observable/range.js
+++ b/perf/micro/current-thread-scheduler/observable/range.js
@@ -5,7 +5,7 @@ module.exports = function range(suite) {
   // add tests
 
   var oldRangeWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread);
-  var newRangeWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate);
+  var newRangeWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/observable/throw.js b/perf/micro/current-thread-scheduler/observable/throw.js
index 58b8f03e7f..ccae7db70d 100644
--- a/perf/micro/current-thread-scheduler/observable/throw.js
+++ b/perf/micro/current-thread-scheduler/observable/throw.js
@@ -3,7 +3,7 @@ var RxNew = require('../../../../index');
 
 module.exports = function _throw(suite) {
   var oldThrowWithCurrentThreadScheduler = RxOld.Observable.throw(new Error('error'), RxOld.Scheduler.currentThread);
-  var newThrowWithCurrentThreadScheduler = RxNew.Observable.throw(new Error('error'), RxNew.Scheduler.immediate);
+  var newThrowWithCurrentThreadScheduler = RxNew.Observable.throw(new Error('error'), RxNew.Scheduler.queue);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/observable/timer.js b/perf/micro/current-thread-scheduler/observable/timer.js
index eebb1f7b95..3886a074ad 100644
--- a/perf/micro/current-thread-scheduler/observable/timer.js
+++ b/perf/micro/current-thread-scheduler/observable/timer.js
@@ -3,7 +3,7 @@ var RxNew = require('../../../../index');
 
 module.exports = function timer(suite) {
   var oldTimerWithCurrentThreadScheduler = RxOld.Observable.timer(25, RxOld.Scheduler.currentThread).take(5);
-  var newTimerWithCurrentThreadScheduler = RxNew.Observable.timer(25, RxNew.Scheduler.immediate).take(5);
+  var newTimerWithCurrentThreadScheduler = RxNew.Observable.timer(25, RxNew.Scheduler.queue).take(5);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/catch.js b/perf/micro/current-thread-scheduler/operators/catch.js
index 7bcd05a36c..c1a822ae95 100644
--- a/perf/micro/current-thread-scheduler/operators/catch.js
+++ b/perf/micro/current-thread-scheduler/operators/catch.js
@@ -4,8 +4,8 @@ var RxNew = require('../../../../index');
 module.exports = function (suite) {
   var oldCatchWithCurrentThreadScheduler = RxOld.Observable.throw(new Error('error'), RxOld.Scheduler.currentThread)
     .catch(function () { return RxOld.Observable.of(25, RxOld.Scheduler.currentThread); });
-  var newCatchWithCurrentThreadScheduler = RxNew.Observable.throw(new Error('error'), RxNew.Scheduler.immediate)
-    .catch(function () { return RxNew.Observable.of(25, RxNew.Scheduler.immediate); });
+  var newCatchWithCurrentThreadScheduler = RxNew.Observable.throw(new Error('error'), RxNew.Scheduler.queue)
+    .catch(function () { return RxNew.Observable.of(25, RxNew.Scheduler.queue); });
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/combinelatest.js b/perf/micro/current-thread-scheduler/operators/combinelatest.js
index c70446c2d3..8f85577964 100644
--- a/perf/micro/current-thread-scheduler/operators/combinelatest.js
+++ b/perf/micro/current-thread-scheduler/operators/combinelatest.js
@@ -11,8 +11,8 @@ module.exports = function (suite) {
     add
   );
   var newCombineLatestWithCurrentThreadScheduler = RxNew.Observable.combineLatest(
-    RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate),
-    RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate),
+    RxNew.Observable.range(0, 25, RxNew.Scheduler.queue),
+    RxNew.Observable.range(0, 25, RxNew.Scheduler.queue),
     add
   );
 
diff --git a/perf/micro/current-thread-scheduler/operators/concat-many.js b/perf/micro/current-thread-scheduler/operators/concat-many.js
index 3086e583e7..76a0904fd3 100644
--- a/perf/micro/current-thread-scheduler/operators/concat-many.js
+++ b/perf/micro/current-thread-scheduler/operators/concat-many.js
@@ -6,9 +6,9 @@ module.exports = function (suite) {
     .concatMap(function (x) {
       return RxOld.Observable.range(x, 25, RxOld.Scheduler.currentThread);
     });
-  var newConcatMapWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate)
+  var newConcatMapWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue)
     .concatMap(function (x) {
-      return RxNew.Observable.range(x, 25, RxNew.Scheduler.immediate);
+      return RxNew.Observable.range(x, 25, RxNew.Scheduler.queue);
     });
 
   function _next(x) { }
diff --git a/perf/micro/current-thread-scheduler/operators/concatall.js b/perf/micro/current-thread-scheduler/operators/concatall.js
index d264989f9a..b049c6034e 100644
--- a/perf/micro/current-thread-scheduler/operators/concatall.js
+++ b/perf/micro/current-thread-scheduler/operators/concatall.js
@@ -10,8 +10,8 @@ module.exports = function (suite) {
   )
     .concatAll();
   var newConcatAllWithCurrentThreadScheduler = RxNew.Observable.fromArray(
-    source.map(function () { return RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate); }),
-    RxNew.Scheduler.immediate
+    source.map(function () { return RxNew.Observable.range(0, 25, RxNew.Scheduler.queue); }),
+    RxNew.Scheduler.queue
   )
     .concatAll();
 
diff --git a/perf/micro/current-thread-scheduler/operators/defaultifempty.js b/perf/micro/current-thread-scheduler/operators/defaultifempty.js
index 551932d706..cdfa6616ff 100644
--- a/perf/micro/current-thread-scheduler/operators/defaultifempty.js
+++ b/perf/micro/current-thread-scheduler/operators/defaultifempty.js
@@ -3,7 +3,7 @@ var RxNew = require('../../../../index');
 
 module.exports = function (suite) {
   var oldDefaultIfEmptyWithCurrentThreadScheduler = RxOld.Observable.empty(RxOld.Scheduler.currentThread).defaultIfEmpty(25);
-  var newDefaultIfEmptyWithCurrentThreadScheduler = RxNew.Observable.empty(RxNew.Scheduler.immediate).defaultIfEmpty(25);
+  var newDefaultIfEmptyWithCurrentThreadScheduler = RxNew.Observable.empty(RxNew.Scheduler.queue).defaultIfEmpty(25);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/exhaust.js b/perf/micro/current-thread-scheduler/operators/exhaust.js
index 44155e2af0..bd4f51027f 100644
--- a/perf/micro/current-thread-scheduler/operators/exhaust.js
+++ b/perf/micro/current-thread-scheduler/operators/exhaust.js
@@ -10,8 +10,8 @@ module.exports = function (suite) {
   )
     .switchFirst();
   var newMergeAllWithCurrentThreadScheduler = RxNew.Observable.fromArray(
-    source.map(function () { return RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate); }),
-    RxNew.Scheduler.immediate
+    source.map(function () { return RxNew.Observable.range(0, 25, RxNew.Scheduler.queue); }),
+    RxNew.Scheduler.queue
   )
     .exhaust();
 
diff --git a/perf/micro/current-thread-scheduler/operators/exhaustMap.js b/perf/micro/current-thread-scheduler/operators/exhaustMap.js
index ecd8c67a00..57ce778987 100644
--- a/perf/micro/current-thread-scheduler/operators/exhaustMap.js
+++ b/perf/micro/current-thread-scheduler/operators/exhaustMap.js
@@ -6,9 +6,9 @@ module.exports = function (suite) {
     .flatMapFirst(function (x) {
       return RxOld.Observable.range(x, 25, RxOld.Scheduler.currentThread);
     });
-  var newMergeMapWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate)
+  var newMergeMapWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue)
     .exhaustMap(function (x) {
-      return RxNew.Observable.range(x, 25, RxNew.Scheduler.immediate);
+      return RxNew.Observable.range(x, 25, RxNew.Scheduler.queue);
     });
 
   function _next(x) { }
diff --git a/perf/micro/current-thread-scheduler/operators/filter.js b/perf/micro/current-thread-scheduler/operators/filter.js
index ab2147f91c..b4e6aa2945 100644
--- a/perf/micro/current-thread-scheduler/operators/filter.js
+++ b/perf/micro/current-thread-scheduler/operators/filter.js
@@ -11,7 +11,7 @@ module.exports = function (suite) {
 
   var oldFilterWithCurrentThreadScheduler = RxOld.Observable.range(0, 50, RxOld.Scheduler.currentThread)
     .filter(divByTwo).filter(divByTen);
-  var newFilterWithCurrentThreadScheduler = RxNew.Observable.range(0, 50, RxNew.Scheduler.immediate)
+  var newFilterWithCurrentThreadScheduler = RxNew.Observable.range(0, 50, RxNew.Scheduler.queue)
     .filter(divByTwo).filter(divByTen);
 
   function _next(x) { }
diff --git a/perf/micro/current-thread-scheduler/operators/groupby.js b/perf/micro/current-thread-scheduler/operators/groupby.js
index 7423f11bf2..0f867df93f 100644
--- a/perf/micro/current-thread-scheduler/operators/groupby.js
+++ b/perf/micro/current-thread-scheduler/operators/groupby.js
@@ -12,7 +12,7 @@ module.exports = function (suite) {
 
   var oldGroupByWithCurrentThreadScheduler = RxOld.Observable.fromArray(source, RxOld.Scheduler.currentThread)
     .groupBy(group);
-  var newGroupByWithCurrentThreadScheduler = RxNew.Observable.fromArray(source, RxNew.Scheduler.immediate)
+  var newGroupByWithCurrentThreadScheduler = RxNew.Observable.fromArray(source, RxNew.Scheduler.queue)
     .groupBy(group);
 
   function _next(x) { }
diff --git a/perf/micro/current-thread-scheduler/operators/ignoreelements.js b/perf/micro/current-thread-scheduler/operators/ignoreelements.js
index cda7bbb4d4..fff7fd49bd 100644
--- a/perf/micro/current-thread-scheduler/operators/ignoreelements.js
+++ b/perf/micro/current-thread-scheduler/operators/ignoreelements.js
@@ -3,7 +3,7 @@ var RxNew = require('../../../../index');
 
 module.exports = function (suite) {
   var oldIgnoreElementsWithCurrentThreadScheduler = RxOld.Observable.range(0, 50, RxOld.Scheduler.currentThread).ignoreElements();
-  var newIgnoreElementsWithCurrentThreadScheduler = RxNew.Observable.range(0, 50, RxNew.Scheduler.immediate).ignoreElements();
+  var newIgnoreElementsWithCurrentThreadScheduler = RxNew.Observable.range(0, 50, RxNew.Scheduler.queue).ignoreElements();
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/map.js b/perf/micro/current-thread-scheduler/operators/map.js
index 74e503e9b7..72b0df8c27 100644
--- a/perf/micro/current-thread-scheduler/operators/map.js
+++ b/perf/micro/current-thread-scheduler/operators/map.js
@@ -10,7 +10,7 @@ module.exports = function (suite) {
     return x + x;
   }
   var oldSelectWithCurrentThreadScheduler = RxOld.Observable.range(0, 50).map(square).map(double);
-  var newSelectWithCurrentThreadScheduler = RxNew.Observable.range(0, 50, RxNew.Scheduler.immediate).map(square).map(double);
+  var newSelectWithCurrentThreadScheduler = RxNew.Observable.range(0, 50, RxNew.Scheduler.queue).map(square).map(double);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/merge.js b/perf/micro/current-thread-scheduler/operators/merge.js
index 666a8717b7..132650b2b3 100644
--- a/perf/micro/current-thread-scheduler/operators/merge.js
+++ b/perf/micro/current-thread-scheduler/operators/merge.js
@@ -4,8 +4,8 @@ var RxNew = require('../../../../index');
 module.exports = function (suite) {
   var oldMergeWithCurrentThreadScheduler = RxOld.Observable.range(0, 250, RxOld.Scheduler.currentThread)
     .merge(RxOld.Observable.range(0, 250, RxOld.Scheduler.currentThread));
-  var newMergeWithCurrentThreadScheduler = RxNew.Observable.range(0, 250, RxNew.Scheduler.immediate)
-    .merge(RxNew.Observable.range(0, 250, RxNew.Scheduler.immediate));
+  var newMergeWithCurrentThreadScheduler = RxNew.Observable.range(0, 250, RxNew.Scheduler.queue)
+    .merge(RxNew.Observable.range(0, 250, RxNew.Scheduler.queue));
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/mergeall.js b/perf/micro/current-thread-scheduler/operators/mergeall.js
index 2f70a8fcae..3ba4b4c466 100644
--- a/perf/micro/current-thread-scheduler/operators/mergeall.js
+++ b/perf/micro/current-thread-scheduler/operators/mergeall.js
@@ -10,8 +10,8 @@ module.exports = function (suite) {
   )
     .mergeAll();
   var newMergeAllWithCurrentThreadScheduler = RxNew.Observable.fromArray(
-    source.map(function () { return RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate); }),
-    RxNew.Scheduler.immediate
+    source.map(function () { return RxNew.Observable.range(0, 25, RxNew.Scheduler.queue); }),
+    RxNew.Scheduler.queue
   )
     .mergeAll();
 
diff --git a/perf/micro/current-thread-scheduler/operators/mergemap-observable-scalar.js b/perf/micro/current-thread-scheduler/operators/mergemap-observable-scalar.js
index ab471ac118..a98cdebd2e 100644
--- a/perf/micro/current-thread-scheduler/operators/mergemap-observable-scalar.js
+++ b/perf/micro/current-thread-scheduler/operators/mergemap-observable-scalar.js
@@ -4,8 +4,8 @@ var RxNew = require('../../../../index');
 module.exports = function (suite) {
   var oldMergeMapWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread)
     .flatMap(RxOld.Observable.return(0, RxOld.Scheduler.currentThread));
-  var newMergeMapWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate)
-    .mergeMapTo(RxNew.Observable.of(0, RxNew.Scheduler.immediate));
+  var newMergeMapWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue)
+    .mergeMapTo(RxNew.Observable.of(0, RxNew.Scheduler.queue));
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/mergemap-observable.js b/perf/micro/current-thread-scheduler/operators/mergemap-observable.js
index 8043ff596b..adf7c00cf1 100644
--- a/perf/micro/current-thread-scheduler/operators/mergemap-observable.js
+++ b/perf/micro/current-thread-scheduler/operators/mergemap-observable.js
@@ -4,8 +4,8 @@ var RxNew = require('../../../../index');
 module.exports = function (suite) {
   var oldMergeMapWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread)
     .flatMap(RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread));
-  var newMergeMapWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate)
-    .mergeMapTo(RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate));
+  var newMergeMapWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue)
+    .mergeMapTo(RxNew.Observable.range(0, 25, RxNew.Scheduler.queue));
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/mergemap-scalar.js b/perf/micro/current-thread-scheduler/operators/mergemap-scalar.js
index 1d86583169..ec453e2dc8 100644
--- a/perf/micro/current-thread-scheduler/operators/mergemap-scalar.js
+++ b/perf/micro/current-thread-scheduler/operators/mergemap-scalar.js
@@ -6,7 +6,7 @@ module.exports = function (suite) {
     .flatMap(function (x) {
       return RxOld.Observable.return(x, RxOld.Scheduler.currentThread);
     });
-  var newMergeMapWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate)
+  var newMergeMapWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue)
     .mergeMap(function (x) {
       return RxNew.Observable.of(x);
     });
diff --git a/perf/micro/current-thread-scheduler/operators/mergemap.js b/perf/micro/current-thread-scheduler/operators/mergemap.js
index efda4313e3..18682733bb 100644
--- a/perf/micro/current-thread-scheduler/operators/mergemap.js
+++ b/perf/micro/current-thread-scheduler/operators/mergemap.js
@@ -6,9 +6,9 @@ module.exports = function (suite) {
     .flatMap(function (x) {
       return RxOld.Observable.range(x, 25, RxOld.Scheduler.currentThread);
     });
-  var newMergeMapWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate)
+  var newMergeMapWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue)
     .mergeMap(function (x) {
-      return RxNew.Observable.range(x, 25, RxNew.Scheduler.immediate);
+      return RxNew.Observable.range(x, 25, RxNew.Scheduler.queue);
     });
 
   function _next(x) { }
diff --git a/perf/micro/current-thread-scheduler/operators/reduce.js b/perf/micro/current-thread-scheduler/operators/reduce.js
index 5fd845d5e8..4e0bfe710b 100644
--- a/perf/micro/current-thread-scheduler/operators/reduce.js
+++ b/perf/micro/current-thread-scheduler/operators/reduce.js
@@ -6,7 +6,7 @@ module.exports = function (suite) {
     return x + x;
   }
   var oldReduceWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread).reduce(add);
-  var newReduceWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate).reduce(add);
+  var newReduceWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue).reduce(add);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/skip.js b/perf/micro/current-thread-scheduler/operators/skip.js
index bb383bc61f..85d7e0b5ca 100644
--- a/perf/micro/current-thread-scheduler/operators/skip.js
+++ b/perf/micro/current-thread-scheduler/operators/skip.js
@@ -3,7 +3,7 @@ var RxNew = require('../../../../index');
 
 module.exports = function (suite) {
   var oldSkipWithCurrentThreadScheduler = RxOld.Observable.range(0, 50, RxOld.Scheduler.currentThread).skip(25);
-  var newSkipWithCurrentThreadScheduler = RxNew.Observable.range(0, 50, RxNew.Scheduler.immediate).skip(25);
+  var newSkipWithCurrentThreadScheduler = RxNew.Observable.range(0, 50, RxNew.Scheduler.queue).skip(25);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/startwith-fromarray.js b/perf/micro/current-thread-scheduler/operators/startwith-fromarray.js
index 83d58cefff..559e4c2c8e 100644
--- a/perf/micro/current-thread-scheduler/operators/startwith-fromarray.js
+++ b/perf/micro/current-thread-scheduler/operators/startwith-fromarray.js
@@ -4,8 +4,8 @@ var RxNew = require('../../../../index');
 module.exports = function (suite) {
   var oldStartWithWithCurrentThreadScheduler = RxOld.Observable.of(25, RxOld.Scheduler.currentThread)
     .startWith(RxOld.Scheduler.currentThread, 5, 5, 5);
-  var newStartWithWithCurrentThreadScheduler = RxNew.Observable.of(25, RxNew.Scheduler.immediate)
-    .startWith(5, 5, 5, RxNew.Scheduler.immediate);
+  var newStartWithWithCurrentThreadScheduler = RxNew.Observable.of(25, RxNew.Scheduler.queue)
+    .startWith(5, 5, 5, RxNew.Scheduler.queue);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/startwith-scalar.js b/perf/micro/current-thread-scheduler/operators/startwith-scalar.js
index 94ab9fd55c..14a9fa8508 100644
--- a/perf/micro/current-thread-scheduler/operators/startwith-scalar.js
+++ b/perf/micro/current-thread-scheduler/operators/startwith-scalar.js
@@ -4,8 +4,8 @@ var RxNew = require('../../../../index');
 module.exports = function (suite) {
   var oldStartWithWithCurrentThreadScheduler = RxOld.Observable.of(25, RxOld.Scheduler.currentThread)
     .startWith(RxOld.Scheduler.currentThread, 5);
-  var newStartWithWithCurrentThreadScheduler = RxNew.Observable.of(25, RxNew.Scheduler.immediate)
-    .startWith(5, RxNew.Scheduler.immediate);
+  var newStartWithWithCurrentThreadScheduler = RxNew.Observable.of(25, RxNew.Scheduler.queue)
+    .startWith(5, RxNew.Scheduler.queue);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/switch.js b/perf/micro/current-thread-scheduler/operators/switch.js
index d009bcc22b..c543d96bc8 100644
--- a/perf/micro/current-thread-scheduler/operators/switch.js
+++ b/perf/micro/current-thread-scheduler/operators/switch.js
@@ -10,8 +10,8 @@ module.exports = function (suite) {
   )
     .switch();
   var newSwitchWithCurrentThreadScheduler = RxNew.Observable.fromArray(
-    source.map(function () { return RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate); }),
-    RxNew.Scheduler.immediate
+    source.map(function () { return RxNew.Observable.range(0, 25, RxNew.Scheduler.queue); }),
+    RxNew.Scheduler.queue
   )
     .switch();
 
diff --git a/perf/micro/current-thread-scheduler/operators/take.js b/perf/micro/current-thread-scheduler/operators/take.js
index f1d39e6b80..530987032d 100644
--- a/perf/micro/current-thread-scheduler/operators/take.js
+++ b/perf/micro/current-thread-scheduler/operators/take.js
@@ -3,7 +3,7 @@ var RxNew = require('../../../../index');
 
 module.exports = function (suite) {
   var oldTakeWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread).take(5);
-  var newTakeWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate).take(5);
+  var newTakeWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue).take(5);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/timeinterval.js b/perf/micro/current-thread-scheduler/operators/timeinterval.js
index e66b81d19e..0c079aca88 100644
--- a/perf/micro/current-thread-scheduler/operators/timeinterval.js
+++ b/perf/micro/current-thread-scheduler/operators/timeinterval.js
@@ -4,8 +4,8 @@ var RxNew = require('../../../../index');
 module.exports = function (suite) {
   var oldTimeIntervalWithCurrentThreadScheduler = RxOld.Observable.interval(25, RxOld.Scheduler.currentThread)
     .take(5).timeInterval(RxOld.Scheduler.currentThread);
-  var newTimeIntervalWithCurrentThreadScheduler = RxNew.Observable.interval(25, RxNew.Scheduler.immediate)
-    .take(5).timeInterval(RxNew.Scheduler.immediate);
+  var newTimeIntervalWithCurrentThreadScheduler = RxNew.Observable.interval(25, RxNew.Scheduler.queue)
+    .take(5).timeInterval(RxNew.Scheduler.queue);
 
   function _next(x) { }
   function _error(e) { }
diff --git a/perf/micro/current-thread-scheduler/operators/toarray.js b/perf/micro/current-thread-scheduler/operators/toarray.js
index 6b1f69be8f..ac29d15d07 100644
--- a/perf/micro/current-thread-scheduler/operators/toarray.js
+++ b/perf/micro/current-thread-scheduler/operators/toarray.js
@@ -3,7 +3,7 @@ var RxNew = require('../../../../index');
 
 module.exports = function (suite) {
   var oldToArrayWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread).toArray();
-  var newToArrayWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate).toArray();
+  var newToArrayWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue).toArray();
 
   function _next(x) { }
   function _error(e) { }