I have the following code and I want to make sure the callback is unregistered. How can I trigger

awaitClose

from my unit test ? I tried to cancel

testScope

but that triggers a

ClosedReceiveChannelException: Channel was closed

since turbine gets also canceled.

private fun someApiCallbackToFlow(api: API) = callbackFlow {
    val callback = object : ApiCallback {
        override fun next(data: Int) {
            trySend("Success")
        }
    }
    api.register(callback)
    awaitClose {
        println("callback unregistered")
        api.unregister(callback)
    }
}


@OptIn(ExperimentalTime::class)
@Test
fun test() = testScope.runTest {
    val api = SomeApi()
    val flow = someApiCallbackToFlow(api)
    flow.test {
        assertEquals(1, api.callbacks.size)
        api.getData()
        assertEquals("Success", awaitItem())
        // how can I check there isn't any callback here?
    }
}

It worked, thanks!