Class and Description |
---|
reactor.core.publisher.DirectProcessor
To be removed in 3.5, prefer clear cut usage of
Sinks . Closest sink
is Sinks.many().multicast().directBestEffort() ,
except it doesn't terminate overflowing downstreams. |
reactor.core.publisher.EmitterProcessor
To be removed in 3.5. Prefer clear cut usage of
Sinks through
variations of Sinks.many().multicast().onBackpressureBuffer() .
This processor was blocking in EmitterProcessor.onNext(Object) .
This behaviour can be implemented with the Sinks API by calling
Sinks.Many.tryEmitNext(Object) and retrying, e.g.:
|
reactor.core.publisher.FluxProcessor
Processors will be removed in 3.5. Prefer using
Sinks.Many instead,
* or see https://github.com/reactor/reactor-core/issues/2431 for alternatives |
reactor.core.publisher.MonoProcessor
Processors will be removed in 3.5. Prefer using
Sinks.One or Sinks.Empty instead,
or see https://github.com/reactor/reactor-core/issues/2431 for alternatives |
reactor.core.publisher.ReplayProcessor
To be removed in 3.5, prefer clear cut usage of
Sinks through
variations under Sinks.many().replay() . |
reactor.core.publisher.UnicastProcessor
to be removed in 3.5, prefer clear cut usage of
Sinks through
variations under Sinks.many().unicast() . |
Constructor and Description |
---|
reactor.core.publisher.UnicastProcessor(Queue<T>, Consumer<? super T>, Disposable) |