1
1
import { Observable } from 'rxjs/Observable' ;
2
+ import { ColdObservable } from 'rxjs/testing/ColdObservable' ;
3
+ import { HotObservable } from 'rxjs/testing/HotObservable' ;
2
4
import { SubscriptionLog } from 'rxjs/testing/SubscriptionLog' ;
3
5
import { parseObservableMarble } from './marbles/parseObservableMarble' ;
4
6
import { parseSubscriptionMarble } from './marbles/parseSubscriptionMarble' ;
@@ -8,6 +10,8 @@ import { TestScheduler } from './scheduler/TestScheduler';
8
10
//workaround TS4029 by explicitly import types and avoid unused import error
9
11
( ( ) => Observable . toString ( ) ) ( ) ;
10
12
( ( ) => SubscriptionLog . toString ( ) ) ( ) ;
13
+ ( ( ) => ColdObservable . toString ( ) ) ( ) ;
14
+ ( ( ) => HotObservable . toString ( ) ) ( ) ;
11
15
12
16
const rxSandbox = {
13
17
create : ( autoFlush : boolean = false , frameTimeFactor : number = 1 ) => {
@@ -17,8 +21,6 @@ const rxSandbox = {
17
21
hot : scheduler . createHotObservable . bind ( scheduler ) as typeof scheduler . createHotObservable ,
18
22
cold : scheduler . createColdObservable . bind ( scheduler ) as typeof scheduler . createColdObservable ,
19
23
flush : scheduler . flush . bind ( scheduler ) as typeof scheduler . flush ,
20
- advanceBy : scheduler . advanceBy . bind ( scheduler ) as typeof scheduler . advanceBy ,
21
- advanceTo : scheduler . advanceTo . bind ( scheduler ) as typeof scheduler . advanceTo ,
22
24
getMarbles : scheduler . getMarbles . bind ( scheduler ) as typeof scheduler . getMarbles ,
23
25
e : < T = string > ( marble : string , value ?: { [ key : string ] : T } | null , error ?: any ) =>
24
26
parseObservableMarble ( marble , value , error , true , frameTimeFactor ) ,
0 commit comments