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

Class AbstractH2StreamMultiplexer.H2Stream

java.lang.Object

org.apache.hc.core5.http2.impl.nio.AbstractH2StreamMultiplexer.H2Stream

Enclosing class:

AbstractH2StreamMultiplexer

static class AbstractH2StreamMultiplexer.H2Stream
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final AbstractH2StreamMultiplexer.H2StreamChannelImpl	channel
private final H2StreamHandler	handler
private final boolean	remoteInitiated

Constructor Summary

Constructors

Modifier	Constructor	Description
private	H2Stream(AbstractH2StreamMultiplexer.H2StreamChannelImpl channel, H2StreamHandler handler, boolean remoteInitiated)

Method Summary

Modifier and Type	Method	Description
(package private) boolean	abort()
(package private) void	appendState(StringBuilder buf)
(package private) void	cancel()
(package private) void	consumeData(ByteBuffer src)
(package private) void	consumeHeader(List<Header> headers)
(package private) void	consumePromise(List<Header> headers)
(package private) int	getId()
(package private) AtomicInteger	getInputWindow()
(package private) AtomicInteger	getOutputWindow()
(package private) HandlerFactory<AsyncPushConsumer>	getPushHandlerFactory()
(package private) void	handle(HttpException ex)
(package private) boolean	isLocalClosed()
(package private) boolean	isLocalReset()
(package private) boolean	isOutputReady()
(package private) boolean	isRemoteClosed()
(package private) boolean	isRemoteInitiated()
(package private) boolean	isTerminated()
(package private) void	localReset(Exception cause, int code)
(package private) void	localReset(Exception cause, H2Error error)
(package private) void	localReset(H2StreamResetException ex)
(package private) void	produceInputCapacityUpdate()
(package private) void	produceOutput()
(package private) void	releaseResources()
(package private) void	reset(Exception cause)
(package private) void	setRemoteEndStream()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

channel

private final AbstractH2StreamMultiplexer.H2StreamChannelImpl channel

handler

private final H2StreamHandler handler

remoteInitiated

private final boolean remoteInitiated

Constructor Details

H2Stream

private H2Stream(AbstractH2StreamMultiplexer.H2StreamChannelImpl channel,
 H2StreamHandler handler,
 boolean remoteInitiated)

Method Details

getId

int getId()

isRemoteInitiated

boolean isRemoteInitiated()

getOutputWindow

AtomicInteger getOutputWindow()

getInputWindow

AtomicInteger getInputWindow()

isTerminated

boolean isTerminated()

isRemoteClosed

boolean isRemoteClosed()

isLocalClosed

boolean isLocalClosed()

isLocalReset

boolean isLocalReset()

setRemoteEndStream

void setRemoteEndStream()

consumePromise

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

Throws:

HttpException

IOException

consumeHeader

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

Throws:

HttpException

IOException

consumeData

void consumeData(ByteBuffer src)
          throws HttpException,
IOException

Throws:

HttpException

IOException

isOutputReady

boolean isOutputReady()

produceOutput

void produceOutput()
            throws HttpException,
IOException

Throws:

HttpException

IOException

produceInputCapacityUpdate

void produceInputCapacityUpdate()
                         throws IOException

Throws:

IOException

reset

void reset(Exception cause)

localReset

void localReset(Exception cause,
 int code)
         throws IOException

Throws:

IOException

localReset

void localReset(Exception cause,
 H2Error error)
         throws IOException

Throws:

IOException

localReset

void localReset(H2StreamResetException ex)
         throws IOException

Throws:

IOException

handle

void handle(HttpException ex)
     throws IOException,
HttpException

Throws:

IOException

HttpException

getPushHandlerFactory

HandlerFactory<AsyncPushConsumer> getPushHandlerFactory()

cancel

void cancel()

abort

boolean abort()

releaseResources

void releaseResources()

appendState

void appendState(StringBuilder buf)

toString

public String toString()

Overrides:

toString in class Object