I’m trying to prove out converting from a

Flow

to an Rx construct. Unfortunately, this never seems to complete.

your

.collect

on the channel will not complete until the channel is closed

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

try

runBlockingTest

and don’t

.join

maybe?

runBlockingTest

unfortunately causes a crash.

This job has not completed yet

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