public Class ResultProcessor<T>

Class Inheritance

Type Parameters

Imports

org.eclipse.jetty.reactive.client.ReactiveResponse

A org.reactivestreams.Processor that receives (typically) a single item of response content of type T from upstream, and produces a single ReactiveResponse.Result that wraps the ReactiveResponse and the response content item.

Field Summary

Modifier and Type	Field and Description
private T	item
private final ReactiveResponse	response

Access	Constructor and Description
public	ResultProcessor(ReactiveResponse response)

Modifier and Type	Method and Description
public void	onComplete() Overrides org.eclipse.jetty.reactive.client.internal.AbstractSingleProcessor.onComplete. Implements org.reactivestreams.Subscriber.onComplete. Successful terminal state.
public void	onNext(T the element signaled item) Implements org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`.

Inherited from org.eclipse.jetty.reactive.client.internal.AbstractSingleProcessor:: cancel downStream downStreamOnNext onError onFailure onRequest onSubscribe toString upStreamCancel upStreamRequest

item	back to summary
private T item

response	back to summary
private final ReactiveResponse response

ResultProcessor	back to summary
public ResultProcessor(ReactiveResponse response)

onComplete back to summary

onComplete	back to summary
public void onComplete() Overrides org.eclipse.jetty.reactive.client.internal.AbstractSingleProcessor.onComplete. Implements org.reactivestreams.Subscriber.onComplete. Doc from org.reactivestreams.Subscriber.onComplete. Successful terminal state. No further events will be sent even if `Subscription#request(long)` is invoked again. Annotations @Override

public void onComplete()

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Annotations

onNext back to summary

onNext	back to summary
public void onNext(T item) Implements org.reactivestreams.Subscriber.onNext. Doc from org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`. Parameters item:T the element signaled Annotations @Override

public void onNext(T item)

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

Parameters

Annotations