org.apache.hc.core5.reactive

Class ReactiveEntityProducer

java.lang.Object

org.apache.hc.core5.reactive.ReactiveEntityProducer

All Implemented Interfaces:

EntityDetails, AsyncDataProducer, AsyncEntityProducer, ResourceHolder

@Contract(threading=SAFE)
public final class ReactiveEntityProducer
extends Object
implements AsyncEntityProducer

An AsyncEntityProducer that subscribes to a Publisher instance, as defined by the Reactive Streams specification.

Since:

5.0

Constructor Summary

Constructors

Constructor and Description
ReactiveEntityProducer(org.reactivestreams.Publisher<ByteBuffer> publisher, long contentLength, ContentType contentType, String contentEncoding) Creates a new ReactiveEntityProducer with the given parameters.

Method Summary

Modifier and Type	Method and Description
int	available()
void	failed(Exception cause)
String	getContentEncoding()
long	getContentLength()
String	getContentType()
Set<String>	getTrailerNames()
boolean	isChunked()
boolean	isRepeatable()
void	produce(DataStreamChannel channel)
void	releaseResources()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveEntityProducer

public ReactiveEntityProducer(org.reactivestreams.Publisher<ByteBuffer> publisher,
                              long contentLength,
                              ContentType contentType,
                              String contentEncoding)

Creates a new ReactiveEntityProducer with the given parameters.

Parameters:

publisher - the publisher of the entity stream.

contentLength - the length of the entity, or -1 if unknown (implies chunked encoding).

contentType - the Content-Type of the entity, or null if none.

contentEncoding - the Content-Encoding of the entity, or null if none.

Method Detail

available

public int available()

Specified by:

available in interface AsyncDataProducer

produce

public void produce(DataStreamChannel channel)
             throws IOException

Specified by:

produce in interface AsyncDataProducer

Throws:

IOException

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface ResourceHolder

isRepeatable

public boolean isRepeatable()

Specified by:

isRepeatable in interface AsyncEntityProducer

failed

public void failed(Exception cause)

Specified by:

failed in interface AsyncEntityProducer

getContentLength

public long getContentLength()

Specified by:

getContentLength in interface EntityDetails

getContentType

public String getContentType()

Specified by:

getContentType in interface EntityDetails

getContentEncoding

public String getContentEncoding()

Specified by:

getContentEncoding in interface EntityDetails

isChunked

public boolean isChunked()

Specified by:

isChunked in interface EntityDetails

getTrailerNames

public Set<String> getTrailerNames()

Specified by:

getTrailerNames in interface EntityDetails