Top Fields Constructors Methods
org.apache.hc.core5.http2.impl.nio

pack-priv Class ClientH2StreamHandler

extends Object
implements H2StreamHandler
Class Inheritance
All Implemented Interfaces
org.apache.hc.core5.http2.impl.nio.H2StreamHandler, org.apache.hc.core5.http.nio.ResourceHolder
Imports
java.io.IOException, java.nio.ByteBuffer, java.util.List, java.util.concurrent.atomic.AtomicBoolean, org.apache.hc.core5.http.EntityDetails, .Header, .HeaderElements, .HttpException, .HttpHeaders, .HttpRequest, .HttpResponse, .HttpStatus, .HttpVersion, .ProtocolException, org.apache.hc.core5.http.impl.BasicHttpConnectionMetrics, .IncomingEntityDetails, org.apache.hc.core5.http.impl.nio.MessageState, org.apache.hc.core5.http.message.StatusLine, org.apache.hc.core5.http.nio.AsyncClientExchangeHandler, .AsyncPushConsumer, .DataStreamChannel, .HandlerFactory, org.apache.hc.core5.http.protocol.HttpCoreContext, .HttpProcessor, org.apache.hc.core5.http2.H2ConnectionException, .H2Error, org.apache.hc.core5.http2.impl.DefaultH2RequestConverter, .DefaultH2ResponseConverter

Field Summary

Modifier and TypeField and 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 volatile MessageState
requestState

private volatile MessageState
responseState

Constructor Summary

AccessConstructor and Description
pack-priv
ClientH2StreamHandler(final H2StreamChannel outputChannel, final HttpProcessor httpProcessor, final BasicHttpConnectionMetrics connMetrics, final AsyncClientExchangeHandler exchangeHandler, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final HttpCoreContext context)

Method Summary

Modifier and TypeMethod and Description
private void
commitRequest(final HttpRequest request, final EntityDetails entityDetails)

public void
consumeData(final ByteBuffer src, final boolean endStream)

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.consumeData.

public void
consumeHeader(final List<Header> headers, final boolean endStream)

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.consumeHeader.

public void
consumePromise(final List<Header> headers)

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.consumePromise.

public void
failed(final Exception cause)

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.failed.

public HandlerFactory<AsyncPushConsumer>
getPushHandlerFactory()

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.getPushHandlerFactory.

public void
handle(final HttpException ex, final boolean endStream)

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.handle.

public boolean
isOutputReady()

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.isOutputReady.

public void
produceOutput()

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.produceOutput.

public void
releaseResources()

Implements org.apache.hc.core5.http.nio.ResourceHolder.releaseResources.

public String
toString()

Overrides java.lang.Object.toString.

Returns a string representation of the object.
public void
updateInputCapacity()

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.updateInputCapacity.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAllwaitwaitwait

Field Detail

connMetricsback to summary
private final BasicHttpConnectionMetrics connMetrics
contextback to summary
private final HttpCoreContext context
dataChannelback to summary
private final DataStreamChannel dataChannel
doneback to summary
private final AtomicBoolean done
exchangeHandlerback to summary
private final AsyncClientExchangeHandler exchangeHandler
failedback to summary
private final AtomicBoolean failed
httpProcessorback to summary
private final HttpProcessor httpProcessor
outputChannelback to summary
private final H2StreamChannel outputChannel
pushHandlerFactoryback to summary
private final HandlerFactory<AsyncPushConsumer> pushHandlerFactory
requestCommittedback to summary
private final AtomicBoolean requestCommitted
requestStateback to summary
private volatile MessageState requestState
responseStateback to summary
private volatile MessageState responseState

Constructor Detail

ClientH2StreamHandlerback to summary
pack-priv ClientH2StreamHandler(final H2StreamChannel outputChannel, final HttpProcessor httpProcessor, final BasicHttpConnectionMetrics connMetrics, final AsyncClientExchangeHandler exchangeHandler, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final HttpCoreContext context)

Method Detail

commitRequestback to summary
private void commitRequest(final HttpRequest request, final EntityDetails entityDetails) throws HttpException, IOException
consumeDataback to summary
public void consumeData(final ByteBuffer src, final boolean endStream) throws HttpException, IOException

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.consumeData.

Annotations
@Override
consumeHeaderback to summary
public void consumeHeader(final List<Header> headers, final boolean endStream) throws HttpException, IOException

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.consumeHeader.

Annotations
@Override
consumePromiseback to summary
public void consumePromise(final List<Header> headers) throws HttpException, IOException

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.consumePromise.

Annotations
@Override
failedback to summary
public void failed(final Exception cause)

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.failed.

Annotations
@Override
getPushHandlerFactoryback to summary
public HandlerFactory<AsyncPushConsumer> getPushHandlerFactory()

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.getPushHandlerFactory.

Annotations
@Override
handleback to summary
public void handle(final HttpException ex, final boolean endStream) throws HttpException, IOException

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.handle.

Annotations
@Override
isOutputReadyback to summary
public boolean isOutputReady()

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.isOutputReady.

Annotations
@Override
produceOutputback to summary
public void produceOutput() throws HttpException, IOException

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.produceOutput.

Annotations
@Override
releaseResourcesback to summary
public void releaseResources()

Implements org.apache.hc.core5.http.nio.ResourceHolder.releaseResources.

Annotations
@Override
toStringback to summary
public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations
@Override
updateInputCapacityback to summary
public void updateInputCapacity() throws IOException

Implements org.apache.hc.core5.http2.impl.nio.H2StreamHandler.updateInputCapacity.

Annotations
@Override