File tree Expand file tree Collapse file tree 1 file changed +29
-29
lines changed
Expand file tree Collapse file tree 1 file changed +29
-29
lines changed Original file line number Diff line number Diff line change @@ -187,16 +187,16 @@ class PausableBufferedTests: XCTestCase {
187187
188188 func testPausedReentrantPauser( ) {
189189 let underlying = scheduler. createHotObservable ( [
190- next ( 110 , 1 ) ,
191- next ( 210 , 2 ) ,
192- next ( 310 , 3 ) ,
193- next ( 410 , 4 ) ,
194- completed ( 500 ) ,
195- ] )
190+ . next( 110 , 1 ) ,
191+ . next( 210 , 2 ) ,
192+ . next( 310 , 3 ) ,
193+ . next( 410 , 4 ) ,
194+ . completed( 500 ) ,
195+ ] )
196196
197197 let pauser = scheduler. createHotObservable ( [
198- next ( 301 , true ) ,
199- ] )
198+ . next( 301 , true ) ,
199+ ] )
200200
201201 let res = scheduler. start ( disposed: 1000 ) { ( ) -> Observable < Int > in
202202 return Observable . create { observer in
@@ -219,11 +219,11 @@ class PausableBufferedTests: XCTestCase {
219219 }
220220
221221 XCTAssertEqual ( res. events, [
222- next ( 301 , 2 ) ,
223- next ( 310 , 3 ) ,
224- next ( 410 , 4 ) ,
225- completed ( 500 ) ,
226- ] )
222+ . next( 301 , 2 ) ,
223+ . next( 310 , 3 ) ,
224+ . next( 410 , 4 ) ,
225+ . completed( 500 ) ,
226+ ] )
227227
228228 XCTAssertEqual ( underlying. subscriptions, [
229229 Subscription ( 200 , 500 ) ,
@@ -232,16 +232,16 @@ class PausableBufferedTests: XCTestCase {
232232
233233 func testPausedReentrantUnderlying( ) {
234234 let underlying = scheduler. createHotObservable ( [
235- next ( 210 , 1 ) ,
236- next ( 210 , 2 ) ,
237- next ( 210 , 3 ) ,
238- next ( 310 , 4 ) ,
239- completed ( 500 ) ,
240- ] )
235+ . next( 210 , 1 ) ,
236+ . next( 210 , 2 ) ,
237+ . next( 210 , 3 ) ,
238+ . next( 310 , 4 ) ,
239+ . completed( 500 ) ,
240+ ] )
241241
242242 let pauser = scheduler. createHotObservable ( [
243- next ( 301 , true ) ,
244- ] )
243+ . next( 301 , true ) ,
244+ ] )
245245
246246 let res = scheduler. start ( disposed: 1000 ) { ( ) -> Observable < Int > in
247247 return Observable . create { observer in
@@ -263,14 +263,14 @@ class PausableBufferedTests: XCTestCase {
263263 }
264264
265265 XCTAssertEqual ( res. events, [
266- next ( 301 , 1 ) ,
267- next ( 301 , 2 ) ,
268- next ( 301 , 3 ) ,
269- next ( 301 , 1 ) ,
270- next ( 301 , 2 ) ,
271- next ( 310 , 4 ) ,
272- completed ( 500 ) ,
273- ] )
266+ . next( 301 , 1 ) ,
267+ . next( 301 , 2 ) ,
268+ . next( 301 , 3 ) ,
269+ . next( 301 , 1 ) ,
270+ . next( 301 , 2 ) ,
271+ . next( 310 , 4 ) ,
272+ . completed( 500 ) ,
273+ ] )
274274
275275 XCTAssertEqual ( underlying. subscriptions, [
276276 Subscription ( 200 , 500 ) ,
You can’t perform that action at this time.
0 commit comments