Huh, what's happening here? ``` @Test fun experiment() = runBlockingTest { PublishProcessor...

# coroutines

[Paul Woitaschek]

Huh, what's happening here?

@Test
  fun experiment() = runBlockingTest {
    PublishProcessor.create<Unit>()
      .replay(1)
      .refCount()
      .asFlow()
      .first()
  }

This fails with java.lang.IllegalStateException: This job has not completed yet oO
Can someone explan this?

[streetsofboston]

Looks like an issue with the coroutine-test library.

You can simplify your failing code like this:

@Test
  fun experiment() = runBlockingTest {
    flow<Unit> {
      suspendCancellableCoroutine<Nothing> {  }
    }
    .first()
  }

[streetsofboston]

The call to first() causes it. If you were to emit at least one item, it all works without an exception being thrown

[streetsofboston]

https://github.com/Kotlin/kotlinx.coroutines/issues/1204
and
https://github.com/Kotlin/kotlinx.coroutines/issues/1222

[voben]

Could we just use runBlocking instead?

[streetsofboston]

Depends. Sometimes you’d like to use the facilities of the TestCoroutineScope in your tests. For this, you must use runBlockingTest.

[Paul Woitaschek]

Lol, I created that first issue 😄