Package org.reactivestreams
Class FlowAdapters.FlowToReactiveProcessor<T,U>
java.lang.Object
org.reactivestreams.FlowAdapters.FlowToReactiveProcessor<T,U>
- Type Parameters:
T
- the input typeU
- the output type
- All Implemented Interfaces:
Flow.Processor<T,
,U> Flow.Publisher<U>
,Flow.Subscriber<T>
- Enclosing class:
FlowAdapters
static final class FlowAdapters.FlowToReactiveProcessor<T,U>
extends Object
implements Flow.Processor<T,U>
Wraps a Reactive Streams Processor and forwards methods of the Flow Processor to it.
-
Field Summary
FieldsModifier and TypeFieldDescription -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
void
void
onSubscribe
(Flow.Subscription subscription) void
subscribe
(Flow.Subscriber<? super U> s)
-
Field Details
-
reactiveStreams
-
-
Constructor Details
-
FlowToReactiveProcessor
-
-
Method Details
-
onSubscribe
- Specified by:
onSubscribe
in interfaceFlow.Subscriber<T>
-
onNext
- Specified by:
onNext
in interfaceFlow.Subscriber<T>
-
onError
- Specified by:
onError
in interfaceFlow.Subscriber<T>
-
onComplete
public void onComplete()- Specified by:
onComplete
in interfaceFlow.Subscriber<T>
-
subscribe
- Specified by:
subscribe
in interfaceFlow.Publisher<T>
-