I assume you're wanting to test the actual concurrency instead of using `TestScheduler`? If actual concurrency isn't an issue, then take a look at `TestScheduler`. If you need the real concurrency, any way to incorporate a `CountDownLatch` to make this and other tests deterministic?