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?

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()
  }

Could we just use

runBlocking

instead?

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

runBlockingTest

.

Lol, I created that first issue 😄