fix(testscheduler): fix return types for creation method

Author: kwonoj

src/scheduler/TestScheduler.ts

@@ -68,9 +68,9 @@ class TestScheduler extends VirtualTimeScheduler {
     throw new Error('not implemented');
   }
 
-  public createColdObservable<T = string>(marble: string, value?: { [key: string]: T }, error?: any): Observable<T>;
-  public createColdObservable<T = string>(message: Array<TestMessage<T>>): Observable<T>;
-  public createColdObservable<T = string>(...args: Array<any>): Observable<T> {
+  public createColdObservable<T = string>(marble: string, value?: { [key: string]: T }, error?: any): ColdObservable<T>;
+  public createColdObservable<T = string>(message: Array<TestMessage<T>>): ColdObservable<T>;
+  public createColdObservable<T = string>(...args: Array<any>): ColdObservable<T> {
     const [marbleValue, value, error] = args;
 
     if (typeof marbleValue === 'string' && marbleValue.indexOf(SubscriptionMarbleToken.SUBSCRIBE) !== -1) {
@@ -80,20 +80,20 @@ class TestScheduler extends VirtualTimeScheduler {
     const messages = Array.isArray(marbleValue)
       ? marbleValue
       : parseObservableMarble(marbleValue, value, error, false, this.frameTimeFactor);
-    const observable = new ColdObservable<T>(messages, this);
+    const observable = new ColdObservable<T>(messages as Array<TestMessage<T | Array<TestMessage<T>>>>, this);
     this.coldObservables.push(observable);
     return observable;
   }
 
-  public createHotObservable<T = string>(marble: string, value?: { [key: string]: T }, error?: any): Observable<T>;
-  public createHotObservable<T = string>(message: Array<TestMessage<T>>): Observable<T>;
-  public createHotObservable<T = string>(...args: Array<any>): Observable<T> {
+  public createHotObservable<T = string>(marble: string, value?: { [key: string]: T }, error?: any): HotObservable<T>;
+  public createHotObservable<T = string>(message: Array<TestMessage<T>>): HotObservable<T>;
+  public createHotObservable<T = string>(...args: Array<any>): HotObservable<T> {
     const [marbleValue, value, error] = args;
 
     const messages = Array.isArray(marbleValue)
       ? marbleValue
       : parseObservableMarble(marbleValue, value, error, false, this.frameTimeFactor);
-    const subject = new HotObservable<T>(messages, this);
+    const subject = new HotObservable<T>(messages as Array<TestMessage<T | Array<TestMessage<T>>>>, this);
     this.hotObservables.push(subject);
     return subject;
   }