A

available() - Method in class org.apache.hc.core5.reactive.ReactiveEntityProducer

 

available() - Method in class org.apache.hc.core5.reactive.ReactiveServerExchangeHandler

 

C

consume(ByteBuffer) - Method in class org.apache.hc.core5.reactive.ReactiveResponseConsumer

 

consume(ByteBuffer) - Method in class org.apache.hc.core5.reactive.ReactiveServerExchangeHandler

 

consumeResponse(HttpResponse, EntityDetails, HttpContext, FutureCallback<Void>) - Method in class org.apache.hc.core5.reactive.ReactiveResponseConsumer

 

F

failed(Exception) - Method in class org.apache.hc.core5.reactive.ReactiveEntityProducer

 

failed(Exception) - Method in class org.apache.hc.core5.reactive.ReactiveResponseConsumer

 

failed(Exception) - Method in class org.apache.hc.core5.reactive.ReactiveServerExchangeHandler

 

G

getContentEncoding() - Method in class org.apache.hc.core5.reactive.ReactiveEntityProducer

 

getContentLength() - Method in class org.apache.hc.core5.reactive.ReactiveEntityProducer

 

getContentType() - Method in class org.apache.hc.core5.reactive.ReactiveEntityProducer

 

getEntityDetails() - Method in class org.apache.hc.core5.reactive.ReactiveResponseConsumer

Returns the response entity details.

getInformationResponse() - Method in class org.apache.hc.core5.reactive.ReactiveResponseConsumer

Returns the intermediate (1xx) HTTP response if one was received.

getResponseFuture() - Method in class org.apache.hc.core5.reactive.ReactiveResponseConsumer

 

getTrailerNames() - Method in class org.apache.hc.core5.reactive.ReactiveEntityProducer

 

getTrailers() - Method in class org.apache.hc.core5.reactive.ReactiveResponseConsumer

Returns the trailers received at the end of the response.

H

handleRequest(HttpRequest, EntityDetails, ResponseChannel, HttpContext) - Method in class org.apache.hc.core5.reactive.ReactiveServerExchangeHandler

 

I

informationResponse(HttpResponse, HttpContext) - Method in class org.apache.hc.core5.reactive.ReactiveResponseConsumer

 

isChunked() - Method in class org.apache.hc.core5.reactive.ReactiveEntityProducer

 

isRepeatable() - Method in class org.apache.hc.core5.reactive.ReactiveEntityProducer

 

O

org.apache.hc.core5.reactive - package org.apache.hc.core5.reactive

 

P

processRequest(HttpRequest, EntityDetails, ResponseChannel, HttpContext, Publisher<ByteBuffer>, Callback<Publisher<ByteBuffer>>) - Method in interface org.apache.hc.core5.reactive.ReactiveRequestProcessor

Processes the actual HTTP request.

produce(DataStreamChannel) - Method in class org.apache.hc.core5.reactive.ReactiveEntityProducer

 

produce(DataStreamChannel) - Method in class org.apache.hc.core5.reactive.ReactiveServerExchangeHandler

 

R

ReactiveEntityProducer - Class in org.apache.hc.core5.reactive

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

ReactiveEntityProducer(Publisher<ByteBuffer>, long, ContentType, String) - Constructor for class org.apache.hc.core5.reactive.ReactiveEntityProducer

Creates a new ReactiveEntityProducer with the given parameters.

ReactiveRequestProcessor - Interface in org.apache.hc.core5.reactive

 

ReactiveResponseConsumer - Class in org.apache.hc.core5.reactive

An AsyncResponseConsumer that publishes the response body through a Publisher, as defined by the Reactive Streams specification.

ReactiveResponseConsumer() - Constructor for class org.apache.hc.core5.reactive.ReactiveResponseConsumer

Creates a ReactiveResponseConsumer.

ReactiveResponseConsumer(FutureCallback<Message<HttpResponse, Publisher<ByteBuffer>>>) - Constructor for class org.apache.hc.core5.reactive.ReactiveResponseConsumer

Creates a ReactiveResponseConsumer that will call back the supplied FutureCallback with a streamable response.

ReactiveServerExchangeHandler - Class in org.apache.hc.core5.reactive

An implementation of AsyncServerExchangeHandler designed to work with reactive streams.

ReactiveServerExchangeHandler(ReactiveRequestProcessor) - Constructor for class org.apache.hc.core5.reactive.ReactiveServerExchangeHandler

Creates a ReactiveServerExchangeHandler.

releaseResources() - Method in class org.apache.hc.core5.reactive.ReactiveEntityProducer

 

releaseResources() - Method in class org.apache.hc.core5.reactive.ReactiveResponseConsumer

 

releaseResources() - Method in class org.apache.hc.core5.reactive.ReactiveServerExchangeHandler

 

S

streamEnd(List<? extends Header>) - Method in class org.apache.hc.core5.reactive.ReactiveResponseConsumer

 

streamEnd(List<? extends Header>) - Method in class org.apache.hc.core5.reactive.ReactiveServerExchangeHandler

 

U

updateCapacity(CapacityChannel) - Method in class org.apache.hc.core5.reactive.ReactiveResponseConsumer

 

updateCapacity(CapacityChannel) - Method in class org.apache.hc.core5.reactive.ReactiveServerExchangeHandler