public class BasicAsyncServerExpectationDecorator extends Object implements AsyncServerExchangeHandler
AsyncServerExchangeHandler implementation that adds support
 for the Expect-Continue handshake to an existing
 AsyncServerExchangeHandler.| Constructor and Description | 
|---|
| BasicAsyncServerExpectationDecorator(AsyncServerExchangeHandler handler) | 
| BasicAsyncServerExpectationDecorator(AsyncServerExchangeHandler handler,
                                    Callback<Exception> exceptionCallback) | 
| Modifier and Type | Method and Description | 
|---|---|
| int | available()Returns the number of bytes immediately available for output. | 
| void | consume(ByteBuffer src)Triggered to pass incoming data to the data consumer. | 
| void | failed(Exception cause)Triggered to signal a failure in data processing. | 
| void | handleRequest(HttpRequest request,
             EntityDetails entityDetails,
             ResponseChannel responseChannel,
             HttpContext context)Processes the actual HTTP request. | 
| void | produce(DataStreamChannel channel)Triggered to signal the ability of the underlying data channel
 to accept more data. | 
| void | releaseResources() | 
| void | streamEnd(List<? extends Header> trailers)Triggered to signal termination of the data stream. | 
| void | updateCapacity(CapacityChannel capacityChannel)Triggered to signal ability of the underlying data stream to receive
 data capacity update. | 
| protected AsyncResponseProducer | verify(HttpRequest request,
      HttpContext context) | 
public BasicAsyncServerExpectationDecorator(AsyncServerExchangeHandler handler, Callback<Exception> exceptionCallback)
public BasicAsyncServerExpectationDecorator(AsyncServerExchangeHandler handler)
protected AsyncResponseProducer verify(HttpRequest request, HttpContext context) throws IOException, HttpException
IOExceptionHttpExceptionpublic final void handleRequest(HttpRequest request, EntityDetails entityDetails, ResponseChannel responseChannel, HttpContext context) throws HttpException, IOException
AsyncServerExchangeHandlerhandleRequest in interface AsyncServerExchangeHandlerrequest - the actual request.entityDetails - the request entity details or null if the request
                      does not enclose an entity.responseChannel - the response channel.context - the actual execution context.HttpExceptionIOExceptionpublic final void updateCapacity(CapacityChannel capacityChannel) throws IOException
AsyncDataConsumerupdateCapacity in interface AsyncDataConsumercapacityChannel - the channel for capacity updates.IOExceptionpublic final void consume(ByteBuffer src) throws IOException
AsyncDataConsumerconsume in interface AsyncDataConsumersrc - data source.IOExceptionpublic final void streamEnd(List<? extends Header> trailers) throws HttpException, IOException
AsyncDataConsumerstreamEnd in interface AsyncDataConsumertrailers - data stream trailers.HttpExceptionIOExceptionpublic final int available()
AsyncDataProduceravailable in interface AsyncDataProducerpublic final void produce(DataStreamChannel channel) throws IOException
AsyncDataProducerproduce in interface AsyncDataProducerchannel - the data channel capable to accepting more data.IOExceptionpublic final void failed(Exception cause)
AsyncDataExchangeHandlerfailed in interface AsyncDataExchangeHandlercause - the cause of the failure.public final void releaseResources()
releaseResources in interface ResourceHolderCopyright © 2005–2022 The Apache Software Foundation. All rights reserved.