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

pack-priv Class ClientPushH2StreamHandler

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, .HttpException, .HttpRequest, .HttpResponse, .HttpVersion, .ProtocolException, org.apache.hc.core5.http.impl.BasicHttpConnectionMetrics, .IncomingEntityDetails, org.apache.hc.core5.http.impl.nio.MessageState, org.apache.hc.core5.http.nio.AsyncPushConsumer, .HandlerFactory, org.apache.hc.core5.http.protocol.HttpCoreContext, .HttpProcessor, org.apache.hc.core5.http2.H2ConnectionException, .H2Error, .H2StreamResetException, org.apache.hc.core5.http2.impl.DefaultH2RequestConverter, .DefaultH2ResponseConverter, org.apache.hc.core5.util.Asserts

Field Summary

Modifier and TypeField and Description
private final BasicHttpConnectionMetrics
connMetrics

private final HttpCoreContext
context

private final AtomicBoolean
done

private volatile AsyncPushConsumer
exchangeHandler

private final AtomicBoolean
failed

private final HttpProcessor
httpProcessor

private final H2StreamChannel
internalOutputChannel

private final HandlerFactory<AsyncPushConsumer>
pushHandlerFactory

private volatile HttpRequest
request

private volatile MessageState
requestState

private volatile MessageState
responseState

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
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
isDone()

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
doneback to summary
private final AtomicBoolean done
exchangeHandlerback to summary
private volatile AsyncPushConsumer exchangeHandler
failedback to summary
private final AtomicBoolean failed
httpProcessorback to summary
private final HttpProcessor httpProcessor
internalOutputChannelback to summary
private final H2StreamChannel internalOutputChannel
pushHandlerFactoryback to summary
private final HandlerFactory<AsyncPushConsumer> pushHandlerFactory
requestback to summary
private volatile HttpRequest request
requestStateback to summary
private volatile MessageState requestState
responseStateback to summary
private volatile MessageState responseState

Constructor Detail

ClientPushH2StreamHandlerback to summary
pack-priv ClientPushH2StreamHandler(final H2StreamChannel outputChannel, final HttpProcessor httpProcessor, final BasicHttpConnectionMetrics connMetrics, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final HttpCoreContext context)

Method Detail

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

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

Annotations
@Override
isDoneback to summary
public boolean isDone()
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