File tree 1 file changed +3
-6
lines changed
reactive/kotlinx-coroutines-reactive/test
1 file changed +3
-6
lines changed Original file line number Diff line number Diff line change @@ -296,12 +296,10 @@ class PublishTest : TestBase() {
296
296
expect(2 )
297
297
// Collector is ready
298
298
send(1 )
299
- expect(3 )
300
299
try {
301
300
send(2 )
302
301
expectUnreached()
303
302
} catch (e: CancellationException ) {
304
- expect(7 )
305
303
// publisher cancellation is async
306
304
latch.countDown()
307
305
throw e
@@ -312,15 +310,14 @@ class PublishTest : TestBase() {
312
310
val collectorLatch = Mutex (true )
313
311
val job = launch {
314
312
published.asFlow().buffer(0 ).collect {
315
- expect(4 )
316
313
collectorLatch.unlock()
317
- hang { expect(6 ) }
314
+ hang { expect(4 ) }
318
315
}
319
316
}
320
317
collectorLatch.lock()
321
- expect(5 )
318
+ expect(3 )
322
319
job.cancelAndJoin()
323
320
latch.await()
324
- finish(8 )
321
+ finish(5 )
325
322
}
326
323
}
You can’t perform that action at this time.
0 commit comments