and the overhead of the consumer probe might be problematic, perhaps use something like `BlackholeConsumer` with a latch or something from onComplete