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 {
187
187
188
188
func testPausedReentrantPauser( ) {
189
189
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
+ ] )
196
196
197
197
let pauser = scheduler. createHotObservable ( [
198
- next ( 301 , true ) ,
199
- ] )
198
+ . next( 301 , true ) ,
199
+ ] )
200
200
201
201
let res = scheduler. start ( disposed: 1000 ) { ( ) -> Observable < Int > in
202
202
return Observable . create { observer in
@@ -219,11 +219,11 @@ class PausableBufferedTests: XCTestCase {
219
219
}
220
220
221
221
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
+ ] )
227
227
228
228
XCTAssertEqual ( underlying. subscriptions, [
229
229
Subscription ( 200 , 500 ) ,
@@ -232,16 +232,16 @@ class PausableBufferedTests: XCTestCase {
232
232
233
233
func testPausedReentrantUnderlying( ) {
234
234
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
+ ] )
241
241
242
242
let pauser = scheduler. createHotObservable ( [
243
- next ( 301 , true ) ,
244
- ] )
243
+ . next( 301 , true ) ,
244
+ ] )
245
245
246
246
let res = scheduler. start ( disposed: 1000 ) { ( ) -> Observable < Int > in
247
247
return Observable . create { observer in
@@ -263,14 +263,14 @@ class PausableBufferedTests: XCTestCase {
263
263
}
264
264
265
265
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
+ ] )
274
274
275
275
XCTAssertEqual ( underlying. subscriptions, [
276
276
Subscription ( 200 , 500 ) ,
You can’t perform that action at this time.
0 commit comments