I’m sorry to keep spamming this channel. I’ll try and keep it down after this. But: I’m having real trouble wrapping my head around the semantics of test dispatchers, specifically around how to test code that involves multiple dispatchers. From a test, I’m trying to call <some channel>.send(<some object>). This yields, which seems to cause dispatcher.advanceUntilIdle() to return (since the consumer is running on another dispatcher), which causes the test dispatcher to try to clean up and exit (even though the test isn’t finished), which causes it to throw IllegalStateException (as if the test had ended). I assume this is it functioning as it’s supposed to, but it leaves me at a little bit of a loss as to how to test this functionality.