Package org.apache.hc.core5.reactive
Class ReactiveDataProducer
java.lang.Object
org.apache.hc.core5.reactive.ReactiveDataProducer
- All Implemented Interfaces:
AsyncDataProducer
,ResourceHolder
,org.reactivestreams.Subscriber<ByteBuffer>
@Contract(threading=SAFE)
final class ReactiveDataProducer
extends Object
implements AsyncDataProducer, org.reactivestreams.Subscriber<ByteBuffer>
An asynchronous data producer that supports Reactive Streams.
- Since:
- 5.0
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final int
private final ArrayDeque
<ByteBuffer> private final AtomicBoolean
private final AtomicReference
<Throwable> private final org.reactivestreams.Publisher
<ByteBuffer> private final AtomicReference
<DataStreamChannel> private final AtomicReference
<org.reactivestreams.Subscription> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionint
Returns the number of bytes immediately available for output.void
void
void
onNext
(ByteBuffer byteBuffer) void
onSubscribe
(org.reactivestreams.Subscription subscription) void
produce
(DataStreamChannel channel) Triggered to signal the ability of the underlying data channel to accept more data.void
(package private) void
setChannel
(DataStreamChannel channel) private void
-
Field Details
-
BUFFER_WINDOW_SIZE
private static final int BUFFER_WINDOW_SIZE- See Also:
-
requestChannel
-
exception
-
complete
-
publisher
-
subscription
-
buffers
-
-
Constructor Details
-
ReactiveDataProducer
-
-
Method Details
-
setChannel
-
onSubscribe
public void onSubscribe(org.reactivestreams.Subscription subscription) - Specified by:
onSubscribe
in interfaceorg.reactivestreams.Subscriber<ByteBuffer>
-
onNext
- Specified by:
onNext
in interfaceorg.reactivestreams.Subscriber<ByteBuffer>
-
onError
- Specified by:
onError
in interfaceorg.reactivestreams.Subscriber<ByteBuffer>
-
onComplete
public void onComplete()- Specified by:
onComplete
in interfaceorg.reactivestreams.Subscriber<ByteBuffer>
-
signalReadiness
private void signalReadiness() -
available
public int available()Description copied from interface:AsyncDataProducer
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.- Specified by:
available
in interfaceAsyncDataProducer
- Returns:
- the number of bytes immediately available for output
-
produce
Description copied from interface:AsyncDataProducer
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.- Specified by:
produce
in interfaceAsyncDataProducer
- Parameters:
channel
- the data channel capable to accepting more data.- Throws:
IOException
-
releaseResources
public void releaseResources()- Specified by:
releaseResources
in interfaceResourceHolder
-