I’m trying to prove out converting from a `Flow` to an Rx construct. Unfortunately, this never seems...

# coroutines

[rook]

I’m trying to prove out converting from a Flow to an Rx construct. Unfortunately, this never seems to complete.

Untitled

[zak.taccardi]

your .collect on the channel will not complete until the channel is closed

[zak.taccardi]

so the job stays active

[rook]

Gotcha. So, I guess the question is, how do I tell the test not to end without processing all the signals?

[zak.taccardi]

try runBlockingTest and don’t .join maybe?

[zak.taccardi]

and launch in the same CoroutineScope

[zak.taccardi]

errr CoroutineContext, not Dispatchers.Default

[rook]

runBlockingTest unfortunately causes a crash.

This job has not completed yet

[Dustin Lam]

You could save a reference to the job and cancel it at the end of the test