Class FlowAdapters.ReactiveToFlowProcessor<T,U>

java.lang.Object

org.reactivestreams.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 Object
implements Processor<T,U>

Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Flow.Processor<? super T, ? extends U>	flow

Constructor Summary

Constructors

Constructor	Description
ReactiveToFlowProcessor(Flow.Processor<? super T, ? extends U> flow)

Method Summary

Modifier and Type	Method	Description
void	onComplete()	Successful terminal state.
void	onError(Throwable t)	Failed terminal state.
void	onNext(T t)	Data notification sent by the Publisher in response to requests to Subscription.request(long).
void	onSubscribe(Subscription subscription)	Invoked after calling Publisher.subscribe(Subscriber).
void	subscribe(Subscriber<? super U> s)	Request Publisher to start streaming data.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

flow

final Flow.Processor<? super T, ? extends U> flow

Constructor Details

ReactiveToFlowProcessor

public ReactiveToFlowProcessor(Flow.Processor<? super T, ? extends U> flow)

Method Details

onSubscribe

public void onSubscribe(Subscription subscription)

Description copied from interface: Subscriber

Invoked after calling Publisher.subscribe(Subscriber).

No data will start flowing until Subscription.request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription.request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription.request(long).

Specified by:

onSubscribe in interface Subscriber<T>

Parameters:

subscription - the Subscription that allows requesting data via Subscription.request(long)

onNext

public void onNext(T t)

Description copied from interface: Subscriber

Data notification sent by the Publisher in response to requests to Subscription.request(long).

Specified by:

onNext in interface Subscriber<T>

Parameters:

t - the element signaled

onError

public void onError(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 interface Subscriber<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 interface Subscriber<T>

subscribe

public void subscribe(Subscriber<? super U> s)

Description copied from interface: Publisher

Request Publisher 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 single Subscriber.

A Subscriber should only subscribe once to a single Publisher.

If the Publisher rejects the subscription attempt or otherwise fails it will signal the error via Subscriber.onError(Throwable).

Specified by:

subscribe in interface Publisher<T>

Parameters:

s - the Subscriber that will consume signals from this Publisher