Jetty ReactiveStreams HttpClient 4.0.3 · org.eclipse.jetty.reactive.client.internal.AbstractSinglePublisher

Modifier and Type	Field and Description
private final AutoLock	lock
private static final Logger	logger
private Subscriber<? super T>	subscriber

Access	Constructor and Description
public	AbstractSinglePublisher()

Method Summary

Modifier and Type	Method and Description
public void	cancel() Implements org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources.
protected void	emitOnComplete(Subscriber<? super T> subscriber)
protected void	emitOnError(Subscriber<? super T> subscriber, Throwable failure)
protected void	emitOnNext(Subscriber<? super T> subscriber, T item)
protected AutoLock	lock()
protected void	onFailure(Subscriber<? super T> subscriber, Throwable failure)
protected abstract void	onRequest(Subscriber<? super T> subscriber, long n)
public void	request(long the strictly positive number of elements to requests to the upstream `Publisher` n) Implements org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method.
private void	reset()
public void	subscribe(Subscriber<? super T> the `Subscriber` that will consume signals from this `Publisher` subscriber) Implements org.reactivestreams.Publisher.subscribe. Request `Publisher` to start streaming data.
protected Subscriber<? super T>	subscriber()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

lock	back to summary
private final AutoLock lock

logger	back to summary
private static final Logger logger

subscriber	back to summary
private Subscriber<? super T> subscriber

AbstractSinglePublisher	back to summary
public AbstractSinglePublisher()

Method Detail

cancel back to summary

cancel	back to summary
public void cancel() Implements org.reactivestreams.Subscription.cancel. Doc from org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources. Data may still be sent to meet previously signalled demand after calling cancel. Annotations @Override

public void cancel()

Implements org.reactivestreams.Subscription.cancel.

Doc from org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Annotations

@Override

emitOnComplete	back to summary
protected void emitOnComplete(Subscriber<? super T> subscriber)

emitOnError	back to summary
protected void emitOnError(Subscriber<? super T> subscriber, Throwable failure)

emitOnNext	back to summary
protected void emitOnNext(Subscriber<? super T> subscriber, T item)

lock	back to summary
protected AutoLock lock()

onFailure	back to summary
protected void onFailure(Subscriber<? super T> subscriber, Throwable failure)

onRequest	back to summary
protected abstract void onRequest(Subscriber<? super T> subscriber, long n)

request back to summary

request	back to summary
public void request(long n) Implements org.reactivestreams.Subscription.request. Doc from org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method. It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the `Publisher` as "effectively unbounded". Whatever has been requested can be sent by the `Publisher` so only signal demand for what can be safely handled. A `Publisher` can send less than is requested if the stream ends but then must emit either `Subscriber#onError(Throwable)` or `Subscriber#onComplete()`. Parameters n:long the strictly positive number of elements to requests to the upstream `Publisher` Annotations @Override

public void request(long n)

Implements org.reactivestreams.Subscription.request.

Doc from org.reactivestreams.Subscription.request.

No events will be sent by a Publisher until demand is signaled via this method.

It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the Publisher as "effectively unbounded".

Whatever has been requested can be sent by the Publisher so only signal demand for what can be safely handled.

A Publisher can send less than is requested if the stream ends but then must emit either Subscriber#onError(Throwable) or Subscriber#onComplete().

Parameters

n:long: the strictly positive number of elements to requests to the upstream Publisher

Annotations

@Override

reset	back to summary
private void reset()

subscribe back to summary

subscribe	back to summary
public void subscribe(Subscriber<? super T> subscriber) Implements org.reactivestreams.Publisher.subscribe. Doc from org.reactivestreams.Publisher.subscribe. 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)`. Parameters subscriber:Subscriber<? super T> the `Subscriber` that will consume signals from this `Publisher` Annotations @Override

public void subscribe(Subscriber<? super T> subscriber)

Implements org.reactivestreams.Publisher.subscribe.

Doc from org.reactivestreams.Publisher.subscribe.

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).

Parameters

subscriber:Subscriber<? super T>: the Subscriber that will consume signals from this Publisher

Annotations

@Override

subscriber	back to summary
protected Subscriber<? super T> subscriber()

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Returns:String a string representation of the object. Annotations @Override

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

public abstract Class AbstractSinglePublisher<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail