Package org.apache.hc.core5.http2.impl.nio

Class ClientH2StreamHandler

java.lang.Object

org.apache.hc.core5.http2.impl.nio.ClientH2StreamHandler

All Implemented Interfaces:

ResourceHolder, H2StreamHandler

class ClientH2StreamHandler
extends Object
implements H2StreamHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final BasicHttpConnectionMetrics	connMetrics
private final HttpCoreContext	context
private final DataStreamChannel	dataChannel
private final AtomicBoolean	done
private final AsyncClientExchangeHandler	exchangeHandler
private final AtomicBoolean	failed
private final HttpProcessor	httpProcessor
private final H2StreamChannel	outputChannel
private final HandlerFactory<AsyncPushConsumer>	pushHandlerFactory
private final AtomicBoolean	requestCommitted
private MessageState	requestState
private MessageState	responseState

Constructor Summary

Constructors

Constructor	Description
ClientH2StreamHandler(H2StreamChannel outputChannel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpCoreContext context)

Method Summary

Modifier and Type	Method	Description
private void	commitRequest(HttpRequest request, EntityDetails entityDetails)
void	consumeData(ByteBuffer src, boolean endStream)
void	consumeHeader(List<Header> headers, boolean endStream)
void	consumePromise(List<Header> headers)
void	failed(Exception cause)
HandlerFactory<AsyncPushConsumer>	getPushHandlerFactory()
void	handle(HttpException ex, boolean endStream)
boolean	isOutputReady()
void	produceOutput()
void	releaseResources()
String	toString()
void	updateInputCapacity()

Methods inherited from class java.lang.Object

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

Field Details

outputChannel

private final H2StreamChannel outputChannel

dataChannel

private final DataStreamChannel dataChannel

httpProcessor

private final HttpProcessor httpProcessor

connMetrics

private final BasicHttpConnectionMetrics connMetrics

exchangeHandler

private final AsyncClientExchangeHandler exchangeHandler

pushHandlerFactory

private final HandlerFactory<AsyncPushConsumer> pushHandlerFactory

context

private final HttpCoreContext context

requestCommitted

private final AtomicBoolean requestCommitted

failed

private final AtomicBoolean failed

done

private final AtomicBoolean done

requestState

private volatile MessageState requestState

responseState

private volatile MessageState responseState

Constructor Details

ClientH2StreamHandler

ClientH2StreamHandler(H2StreamChannel outputChannel,
 HttpProcessor httpProcessor,
 BasicHttpConnectionMetrics connMetrics,
 AsyncClientExchangeHandler exchangeHandler,
 HandlerFactory<AsyncPushConsumer> pushHandlerFactory,
 HttpCoreContext context)

Method Details

getPushHandlerFactory

public HandlerFactory<AsyncPushConsumer> getPushHandlerFactory()

Specified by:

getPushHandlerFactory in interface H2StreamHandler

isOutputReady

public boolean isOutputReady()

Specified by:

isOutputReady in interface H2StreamHandler

commitRequest

private void commitRequest(HttpRequest request,
 EntityDetails entityDetails)
                    throws HttpException,
IOException

Throws:

HttpException

IOException

produceOutput

public void produceOutput()
                   throws HttpException,
IOException

Specified by:

produceOutput in interface H2StreamHandler

Throws:

HttpException

IOException

consumePromise

public void consumePromise(List<Header> headers)
                    throws HttpException,
IOException

Specified by:

consumePromise in interface H2StreamHandler

Throws:

HttpException

IOException

consumeHeader

public void consumeHeader(List<Header> headers,
 boolean endStream)
                   throws HttpException,
IOException

Specified by:

consumeHeader in interface H2StreamHandler

Throws:

HttpException

IOException

updateInputCapacity

public void updateInputCapacity()
                         throws IOException

Specified by:

updateInputCapacity in interface H2StreamHandler

Throws:

IOException

consumeData

public void consumeData(ByteBuffer src,
 boolean endStream)
                 throws HttpException,
IOException

Specified by:

consumeData in interface H2StreamHandler

Throws:

HttpException

IOException

handle

public void handle(HttpException ex,
 boolean endStream)
            throws HttpException,
IOException

Specified by:

handle in interface H2StreamHandler

Throws:

HttpException

IOException

failed

public void failed(Exception cause)

Specified by:

failed in interface H2StreamHandler

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface ResourceHolder

toString

public String toString()

Overrides:

toString in class Object