Apache HttpComponents Core Reactive Extensions 5.2.4 · org.apache.hc.core5.reactive.ReactiveDataProducer

Modifier and Type	Field and Description
private static final int	BUFFER_WINDOW_SIZE
private final ArrayDeque<ByteBuffer>	buffers
private final AtomicBoolean	complete
private final AtomicReference<Throwable>	exception
private final Publisher<ByteBuffer>	publisher
private final AtomicReference<DataStreamChannel>	requestChannel
private final AtomicReference<Subscription>	subscription

Access	Constructor and Description
public	ReactiveDataProducer(final Publisher<ByteBuffer> publisher)

Method Summary

Modifier and Type	Method and Description
public int	available() Implements org.apache.hc.core5.http.nio.AsyncDataProducer.available. Returns the number of bytes immediately available for output.
public void	onComplete() Implements org.reactivestreams.Subscriber.onComplete. Successful terminal state.
public void	onError(final Throwable the throwable signaled throwable) Implements org.reactivestreams.Subscriber.onError. Failed terminal state.
public void	onNext(final ByteBuffer the element signaled byteBuffer) Implements org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`.
public void	onSubscribe(final Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` subscription) Implements org.reactivestreams.Subscriber.onSubscribe. Invoked after calling `Publisher#subscribe(Subscriber)`.
public void	produce(final DataStreamChannel the data channel capable to accepting more data. channel) Implements org.apache.hc.core5.http.nio.AsyncDataProducer.produce. Triggered to signal the ability of the underlying data channel to accept more data.
public void	releaseResources() Implements org.apache.hc.core5.http.nio.ResourceHolder.releaseResources.
pack-priv void	setChannel(final DataStreamChannel channel)
private void	signalReadiness()

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

BUFFER_WINDOW_SIZE	back to summary
private static final int BUFFER_WINDOW_SIZE

buffers	back to summary
private final ArrayDeque<ByteBuffer> buffers

complete	back to summary
private final AtomicBoolean complete

exception	back to summary
private final AtomicReference<Throwable> exception

publisher	back to summary
private final Publisher<ByteBuffer> publisher

requestChannel	back to summary
private final AtomicReference<DataStreamChannel> requestChannel

subscription	back to summary
private final AtomicReference<Subscription> subscription

ReactiveDataProducer	back to summary
public ReactiveDataProducer(final Publisher<ByteBuffer> publisher)

Method Detail

available	back to summary
public int available() Implements org.apache.hc.core5.http.nio.AsyncDataProducer.available. Doc from org.apache.hc.core5.http.nio.AsyncDataProducer.available. Returns the number of bytes immediately available for output. This method can be used as a hint to control output events of the underlying I/O session. Returns:int the number of bytes immediately available for output Annotations @Override

available

back to summary

public int available()

Implements org.apache.hc.core5.http.nio.AsyncDataProducer.available.

Doc from org.apache.hc.core5.http.nio.AsyncDataProducer.available.

Returns the number of bytes immediately available for output. This method can be used as a hint to control output events of the underlying I/O session.

Returns:int

the number of bytes immediately available for output

Annotations

@Override

onComplete back to summary

onComplete	back to summary
public void 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()

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

onError back to summary

onError	back to summary
public void onError(final Throwable throwable) Implements org.reactivestreams.Subscriber.onError. Doc from org.reactivestreams.Subscriber.onError. Failed terminal state. No further events will be sent even if `Subscription#request(long)` is invoked again. Parameters throwable:Throwable the throwable signaled Annotations @Override

public void onError(final Throwable throwable)

Implements org.reactivestreams.Subscriber.onError.

Doc from org.reactivestreams.Subscriber.onError.

Failed terminal state.

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

Parameters

throwable:Throwable: the throwable signaled

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(final ByteBuffer byteBuffer) 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 byteBuffer:ByteBuffer the element signaled Annotations @Override

public void onNext(final ByteBuffer byteBuffer)

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

byteBuffer:ByteBuffer: the element signaled

Annotations

@Override

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(final Subscription subscription) Implements org.reactivestreams.Subscriber.onSubscribe. Doc from org.reactivestreams.Subscriber.onSubscribe. 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)`. Parameters subscription:Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` Annotations @Override

public void onSubscribe(final Subscription subscription)

Implements org.reactivestreams.Subscriber.onSubscribe.

Doc from org.reactivestreams.Subscriber.onSubscribe.

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

Parameters

subscription:Subscription: the Subscription that allows requesting data via Subscription#request(long)

Annotations

@Override

produce	back to summary
public void produce(final DataStreamChannel channel) throws IOException Implements org.apache.hc.core5.http.nio.AsyncDataProducer.produce. Doc from org.apache.hc.core5.http.nio.AsyncDataProducer.produce. Triggered to signal the ability of the underlying data channel to accept more data. The data producer can choose to write data immediately inside the call or asynchronously at some later point. Parameters channel:DataStreamChannel the data channel capable to accepting more data. Annotations @Override

produce

back to summary

public void produce(final DataStreamChannel channel) throws IOException

Implements org.apache.hc.core5.http.nio.AsyncDataProducer.produce.

Doc from org.apache.hc.core5.http.nio.AsyncDataProducer.produce.

Triggered to signal the ability of the underlying data channel to accept more data. The data producer can choose to write data immediately inside the call or asynchronously at some later point.

Parameters