Class FlowAdapters.ReactiveToFlowProcessor<T,U>
- java.lang.Object
-
- org.reactivestreams.FlowAdapters.ReactiveToFlowProcessor<T,U>
-
- Type Parameters:
T
- the input typeU
- 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.
-
-
Constructor Summary
Constructors Constructor Description ReactiveToFlowProcessor(java.util.concurrent.Flow.Processor<? super T,? extends U> flow)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onComplete()
Successful terminal state.void
onError(java.lang.Throwable t)
Failed terminal state.void
onNext(T t)
Data notification sent by thePublisher
in response to requests toSubscription.request(long)
.void
onSubscribe(Subscription subscription)
Invoked after callingPublisher.subscribe(Subscriber)
.void
subscribe(Subscriber<? super U> s)
RequestPublisher
to start streaming data.
-
-
-
Method Detail
-
onSubscribe
public void onSubscribe(Subscription subscription)
Description copied from interface:Subscriber
Invoked after callingPublisher.subscribe(Subscriber)
.No data will start flowing until
Subscription.request(long)
is invoked.It is the responsibility of this
Subscriber
instance to callSubscription.request(long)
whenever more data is wanted.The
Publisher
will send notifications only in response toSubscription.request(long)
.- Specified by:
onSubscribe
in interfaceSubscriber<T>
- Parameters:
subscription
- theSubscription
that allows requesting data viaSubscription.request(long)
-
onNext
public void onNext(T t)
Description copied from interface:Subscriber
Data notification sent by thePublisher
in response to requests toSubscription.request(long)
.- Specified by:
onNext
in interfaceSubscriber<T>
- Parameters:
t
- the element signaled
-
onError
public void onError(java.lang.Throwable t)
Description copied from interface:Subscriber
Failed terminal state.No further events will be sent even if
Subscription.request(long)
is invoked again.- Specified by:
onError
in interfaceSubscriber<T>
- Parameters:
t
- the throwable signaled
-
onComplete
public void onComplete()
Description copied from interface:Subscriber
Successful terminal state.No further events will be sent even if
Subscription.request(long)
is invoked again.- Specified by:
onComplete
in interfaceSubscriber<T>
-
subscribe
public void subscribe(Subscriber<? super U> s)
Description copied from interface:Publisher
RequestPublisher
to start streaming data.This is a "factory method" and can be called multiple times, each time starting a new
Subscription
.Each
Subscription
will work for only a singleSubscriber
.A
Subscriber
should only subscribe once to a singlePublisher
.If the
Publisher
rejects the subscription attempt or otherwise fails it will signal the error viaSubscriber.onError(Throwable)
.- Specified by:
subscribe
in interfacePublisher<T>
- Parameters:
s
- theSubscriber
that will consume signals from thisPublisher
-
-