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:
java.util.concurrent.Flow.Processor<T,U>
,java.util.concurrent.Flow.Publisher<U>
,java.util.concurrent.Flow.Subscriber<T>
- Enclosing class:
- FlowAdapters
static final class FlowAdapters.FlowToReactiveProcessor<T,U> extends java.lang.Object implements java.util.concurrent.Flow.Processor<T,U>
Wraps a Reactive Streams Processor and forwards methods of the Flow Processor to it.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) Processor<? super T,? extends U>
reactiveStreams
-
Constructor Summary
Constructors Constructor Description FlowToReactiveProcessor(Processor<? super T,? extends U> reactive)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onComplete()
void
onError(java.lang.Throwable t)
void
onNext(T t)
void
onSubscribe(java.util.concurrent.Flow.Subscription subscription)
void
subscribe(java.util.concurrent.Flow.Subscriber<? super U> s)
-
-
-
Method Detail
-
onSubscribe
public void onSubscribe(java.util.concurrent.Flow.Subscription subscription)
- Specified by:
onSubscribe
in interfacejava.util.concurrent.Flow.Subscriber<T>
-
onNext
public void onNext(T t)
- Specified by:
onNext
in interfacejava.util.concurrent.Flow.Subscriber<T>
-
onError
public void onError(java.lang.Throwable t)
- Specified by:
onError
in interfacejava.util.concurrent.Flow.Subscriber<T>
-
onComplete
public void onComplete()
- Specified by:
onComplete
in interfacejava.util.concurrent.Flow.Subscriber<T>
-
-