Like emitter, but with a ready() backpressure method. It also only supports a single active subscriber. (Useful for testing stream operators and sinks.)
Like emitter, but with a ready() backpressure method. It also only supports a single active subscriber. (Useful for testing stream operators and sinks.)