@@ -19,20 +19,6 @@ class TestScheduler extends VirtualTimeScheduler {
19
19
super ( VirtualAction , Number . POSITIVE_INFINITY ) ;
20
20
}
21
21
22
- private materializeInnerObservable < T > ( observable : Observable < any > , outerFrame : number ) : Array < TestMessage < T > > {
23
- const innerObservableMetadata : Array < TestMessage < T > > = [ ] ;
24
- const pushMetaData = ( notification : Notification < T > ) =>
25
- innerObservableMetadata . push ( new TestMessageValue < T > ( this . frame - outerFrame , notification ) ) ;
26
-
27
- observable . subscribe (
28
- value => pushMetaData ( Notification . createNext ( value ) ) ,
29
- err => pushMetaData ( Notification . createError ( err ) ) ,
30
- ( ) => pushMetaData ( Notification . createComplete ( ) )
31
- ) ;
32
-
33
- return innerObservableMetadata ;
34
- }
35
-
36
22
public getMarbles < T = string > ( observable : Observable < T > , unsubscriptionMarbles : string | null = null ) {
37
23
if ( this . autoFlush ) {
38
24
throw new Error ( 'not implemented' ) ;
@@ -102,6 +88,20 @@ class TestScheduler extends VirtualTimeScheduler {
102
88
this . hotObservables . push ( subject ) ;
103
89
return subject ;
104
90
}
91
+
92
+ private materializeInnerObservable < T > ( observable : Observable < any > , outerFrame : number ) : Array < TestMessage < T > > {
93
+ const innerObservableMetadata : Array < TestMessage < T > > = [ ] ;
94
+ const pushMetaData = ( notification : Notification < T > ) =>
95
+ innerObservableMetadata . push ( new TestMessageValue < T > ( this . frame - outerFrame , notification ) ) ;
96
+
97
+ observable . subscribe (
98
+ value => pushMetaData ( Notification . createNext ( value ) ) ,
99
+ err => pushMetaData ( Notification . createError ( err ) ) ,
100
+ ( ) => pushMetaData ( Notification . createComplete ( ) )
101
+ ) ;
102
+
103
+ return innerObservableMetadata ;
104
+ }
105
105
}
106
106
107
107
export { TestScheduler } ;
0 commit comments