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

pack-priv Class ServerPushH2StreamHandler

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, .HttpStatus, .HttpVersion, .ProtocolException, org.apache.hc.core5.http.impl.BasicHttpConnectionMetrics, org.apache.hc.core5.http.impl.nio.MessageState, org.apache.hc.core5.http.nio.AsyncPushConsumer, .AsyncPushProducer, .DataStreamChannel, .HandlerFactory, .ResponseChannel, org.apache.hc.core5.http.protocol.HttpContext, .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 AtomicBoolean
failed

private final HttpProcessor
httpProcessor

private final H2StreamChannel
outputChannel

private final AsyncPushProducer
pushProducer

private volatile MessageState
requestState

private final AtomicBoolean
responseCommitted

private volatile MessageState
responseState

Constructor Summary

AccessConstructor and Description
pack-priv
ServerPushH2StreamHandler(final H2StreamChannel outputChannel, final HttpProcessor httpProcessor, final BasicHttpConnectionMetrics connMetrics, final AsyncPushProducer pushProducer, final HttpCoreContext context)

Method Summary

Modifier and TypeMethod and Description
private void
commitInformation(final HttpResponse response)

private void
commitPromise(final HttpRequest promise, final AsyncPushProducer pushProducer)

private void
commitResponse(final HttpResponse response, final EntityDetails responseEntityDetails)

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> requestHeaders, final boolean requestEndStream)

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
failedback to summary
private final AtomicBoolean failed
httpProcessorback to summary
private final HttpProcessor httpProcessor
outputChannelback to summary
private final H2StreamChannel outputChannel
pushProducerback to summary
private final AsyncPushProducer pushProducer
requestStateback to summary
private volatile MessageState requestState
responseCommittedback to summary
private final AtomicBoolean responseCommitted
responseStateback to summary
private volatile MessageState responseState

Constructor Detail

ServerPushH2StreamHandlerback to summary
pack-priv ServerPushH2StreamHandler(final H2StreamChannel outputChannel, final HttpProcessor httpProcessor, final BasicHttpConnectionMetrics connMetrics, final AsyncPushProducer pushProducer, final HttpCoreContext context)

Method Detail

commitInformationback to summary
private void commitInformation(final HttpResponse response) throws IOException, HttpException
commitPromiseback to summary
private void commitPromise(final HttpRequest promise, final AsyncPushProducer pushProducer) throws HttpException, IOException
commitResponseback to summary
private void commitResponse(final HttpResponse response, final EntityDetails responseEntityDetails) 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> requestHeaders, final boolean requestEndStream) 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