Class FlowAdapters.ReactiveToFlowProcessor<T,​U>

  • Type Parameters:
    T - the input type
    U - the output type
    All Implemented Interfaces:
    Processor<T,​U>, Publisher<U>, Subscriber<T>
    Enclosing class:
    FlowAdapters

    static final class FlowAdapters.ReactiveToFlowProcessor<T,​U>
    extends java.lang.Object
    implements Processor<T,​U>
    Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.