refactor(TestScheduler): rename startScheduler() function to start()

Author: tusharmath

src/testing/TestScheduler.ts

@@ -89,8 +89,8 @@ export class TestScheduler implements IScheduler {
     this.queue = residual
   }
 
-  startScheduler<T> (f: () => IObservable<T>,
-                     timing: {start: number, stop: number} = DEFAULT_TIMING): TestObserver<T> {
+  start<T> (f: () => IObservable<T>,
+            timing: {start: number, stop: number} = DEFAULT_TIMING): TestObserver<T> {
     var subscription: ISubscription
     var resultsObserver = new TestObserver(this);
     this.scheduleAbsolute(() => subscription = f().subscribe(resultsObserver, this), timing.start)
@@ -101,11 +101,11 @@ export class TestScheduler implements IScheduler {
     return resultsObserver
   }
 
-  cold <T> (events: Array<IEvent>) {
+  Cold <T> (events: Array<IEvent>) {
     return ColdTestObservable(this, events)
   }
 
-  hot <T> (events: Array<IEvent>) {
+  Hot <T> (events: Array<IEvent>) {
     return HotTestObservable(this, events)
   }
 

test/test.FromArray.ts

@@ -14,7 +14,7 @@ const {next, error} = ReactiveTest
 test(t => {
   const sh = TestScheduler.of()
   const testFunction = (x: any) => x === 2 ? x.do() : x * 100
-  const {results} = sh.startScheduler(() => map(testFunction, fromArray([1, 2, 3])))
+  const {results} = sh.start(() => map(testFunction, fromArray([1, 2, 3])))
   t.deepEqual(results, [
     next(201, 100),
     error(201, new TypeError())

test/test.IntervalObservable.ts

@@ -13,7 +13,7 @@ const {next, error} = ReactiveTest
 
 test('subscribe()', t => {
   const sh = TestScheduler.of()
-  const {results} = sh.startScheduler<number>(() => interval(200))
+  const {results} = sh.start<number>(() => interval(200))
   t.deepEqual(results, [
     next(400, 0),
     next(600, 1),

test/test.JoinObservable.ts

@@ -10,24 +10,24 @@ const {next, complete} = ReactiveTest
 
 test('subscribe()', t => {
   const sh = TestScheduler.of()
-  const sa$$ = sh.cold([
+  const sa$$ = sh.Cold([
     next(10, 'A0'),
     next(20, 'A1'),
     next(30, 'A2'),
     complete(40)
   ])
-  const sb$$ = sh.cold([
+  const sb$$ = sh.Cold([
     next(10, 'B0'),
     next(20, 'B1'),
     next(30, 'B2'),
     complete(40)
   ])
-  const s$$ = sh.cold([
+  const s$$ = sh.Cold([
     next(10, sa$$),
     next(20, sb$$),
     complete(100)
   ])
-  const {results} = sh.startScheduler<number>(() => join(s$$))
+  const {results} = sh.start<number>(() => join(s$$))
 
   t.deepEqual(results, [
     next(220, 'A0'),
@@ -45,28 +45,28 @@ test('subscribe():hot', t => {
   const sh = TestScheduler.of()
 
   // start(210)
-  const sa$$ = sh.hot([
+  const sa$$ = sh.Hot([
     next(211, 'A0'),
     next(220, 'A1'),
     next(230, 'A2'),
     complete(240)
   ])
 
   // start(220)
-  const sb$$ = sh.hot([
+  const sb$$ = sh.Hot([
     next(205, 'B0'),
     next(215, 'B1'),
     next(225, 'B2'),
     complete(340)
   ])
 
   // start(210)
-  const s$$ = sh.hot([
+  const s$$ = sh.Hot([
     next(210, sa$$),
     next(220, sb$$),
     complete(300)
   ])
-  const {results} = sh.startScheduler<number>(() => join(s$$))
+  const {results} = sh.start<number>(() => join(s$$))
   t.deepEqual(results, [
     next(211, 'A0'),
     next(220, 'A1'),

test/test.MapObservable.ts

@@ -13,13 +13,13 @@ const {next, complete} = ReactiveTest
 
 test('MapObservable.subscribe()', t => {
   const sh = TestScheduler.of()
-  const $ = sh.cold<number>([
+  const $ = sh.Cold<number>([
     next(210, 0),
     next(220, 10),
     next(230, 20),
     complete(250)
   ])
-  const {results} = sh.startScheduler(() => map<number>((x: number) => x + 1, $))
+  const {results} = sh.start(() => map<number>((x: number) => x + 1, $))
   t.deepEqual(results, [
     next(410, 1),
     next(420, 11),
@@ -30,14 +30,14 @@ test('MapObservable.subscribe()', t => {
 
 test('MapObservable.subscribe():HOT', t => {
   const sh = TestScheduler.of()
-  const $ = sh.hot<number>([
+  const $ = sh.Hot<number>([
     next(100, -10),
     next(210, 0),
     next(220, 10),
     next(230, 20),
     complete(250)
   ])
-  const {results} = sh.startScheduler(() => map<number>((x: number) => x + 1, $))
+  const {results} = sh.start(() => map<number>((x: number) => x + 1, $))
   t.deepEqual(results, [
     next(210, 1),
     next(220, 11),

test/test.ScanObservable.ts

@@ -11,15 +11,15 @@ const {next, complete} = ReactiveTest
 
 test('ScanObservable.subscribe()', t => {
   const sh = TestScheduler.of()
-  const $ = sh.cold<number>([
+  const $ = sh.Cold<number>([
     next(210, 0),
     next(220, 1),
     next(230, 2),
     next(240, 3),
     next(250, 4),
     complete(250)
   ])
-  const {results} = sh.startScheduler(() => scan((a, b) => a + b, 0, $))
+  const {results} = sh.start(() => scan((a, b) => a + b, 0, $))
   t.deepEqual(results, [
     next(410, 0),
     next(420, 1),

test/test.SliceObservable.ts

@@ -12,15 +12,15 @@ import {ReactiveTest} from '../src/testing/ReactiveTest';
 const {next, complete} = ReactiveTest
 test('takeN(0, 3)', t => {
   const sh = TestScheduler.of()
-  const ob$ = sh.cold([
+  const ob$ = sh.Cold([
     next(0, 1),
     next(10, 2),
     next(20, 3),
     next(30, 4),
     next(40, 5),
     complete(50)
   ])
-  const {results} = sh.startScheduler(() => slice(0, 3, ob$))
+  const {results} = sh.start(() => slice(0, 3, ob$))
   t.deepEqual(results, [
     next(200, 1),
     next(210, 2),
@@ -31,7 +31,7 @@ test('takeN(0, 3)', t => {
 
 test('takeN(0, Infinity)', t => {
   const sh = TestScheduler.of()
-  const ob$ = sh.cold([
+  const ob$ = sh.Cold([
     next(0, 1),
     next(10, 2),
     next(20, 3),
@@ -40,7 +40,7 @@ test('takeN(0, Infinity)', t => {
     complete(50),
     next(60, 6)
   ])
-  const {results} = sh.startScheduler(() => slice(0, Infinity, ob$))
+  const {results} = sh.start(() => slice(0, Infinity, ob$))
   t.deepEqual(results, [
     next(200, 1),
     next(210, 2),
@@ -53,15 +53,15 @@ test('takeN(0, Infinity)', t => {
 
 test('takeN(1, 3)', t => {
   const sh = TestScheduler.of()
-  const ob$ = sh.cold([
+  const ob$ = sh.Cold([
     next(0, 1),
     next(10, 2),
     next(20, 3),
     next(30, 4),
     next(40, 5),
     complete(50)
   ])
-  const {results} = sh.startScheduler(() => slice(1, 3, ob$))
+  const {results} = sh.start(() => slice(1, 3, ob$))
   t.deepEqual(results, [
     next(210, 2),
     next(220, 3),