Class | Description |
---|---|
SingleSubscriberProcessor<T,R> |
A
Processor that only allows a single Subscriber |
SingleThreadedBufferingProcessor<R,T> |
A Reactive streams
Processor designed to be used within a single thread and manage
back pressure state. |