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 java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
private AbstractH2StreamMultiplexer.H2StreamChannelImpl	channel
private H2StreamHandler	handler
private 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(java.lang.StringBuilder buf)
(package private) void	cancel()
(package private) void	consumeData(java.nio.ByteBuffer src)
(package private) void	consumeHeader(java.util.List<Header> headers)
(package private) void	consumePromise(java.util.List<Header> headers)
(package private) int	getId()
(package private) java.util.concurrent.atomic.AtomicInteger	getInputWindow()
(package private) java.util.concurrent.atomic.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(java.lang.Exception cause, int code)
(package private) void	localReset(java.lang.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(java.lang.Exception cause)
(package private) void	setRemoteEndStream()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

channel

private final AbstractH2StreamMultiplexer.H2StreamChannelImpl channel

handler

private final H2StreamHandler handler

remoteInitiated

private final boolean remoteInitiated

Constructor Detail

H2Stream

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

Method Detail

getId

int getId()

isRemoteInitiated

boolean isRemoteInitiated()

getOutputWindow

java.util.concurrent.atomic.AtomicInteger getOutputWindow()

getInputWindow

java.util.concurrent.atomic.AtomicInteger getInputWindow()

isTerminated

boolean isTerminated()

isRemoteClosed

boolean isRemoteClosed()

isLocalClosed

boolean isLocalClosed()

isLocalReset

boolean isLocalReset()

setRemoteEndStream

void setRemoteEndStream()

consumePromise

void consumePromise(java.util.List<Header> headers)
             throws HttpException,
                    java.io.IOException

Throws:

HttpException

java.io.IOException

consumeHeader

void consumeHeader(java.util.List<Header> headers)
            throws HttpException,
                   java.io.IOException

Throws:

HttpException

java.io.IOException

consumeData

void consumeData(java.nio.ByteBuffer src)
          throws HttpException,
                 java.io.IOException

Throws:

HttpException

java.io.IOException

isOutputReady

boolean isOutputReady()

produceOutput

void produceOutput()
            throws HttpException,
                   java.io.IOException

Throws:

HttpException

java.io.IOException

produceInputCapacityUpdate

void produceInputCapacityUpdate()
                         throws java.io.IOException

Throws:

java.io.IOException

reset

void reset(java.lang.Exception cause)

localReset

void localReset(java.lang.Exception cause,
                int code)
         throws java.io.IOException

Throws:

java.io.IOException

localReset

void localReset(java.lang.Exception cause,
                H2Error error)
         throws java.io.IOException

Throws:

java.io.IOException

localReset

void localReset(H2StreamResetException ex)
         throws java.io.IOException

Throws:

java.io.IOException

handle

void handle(HttpException ex)
     throws java.io.IOException,
            HttpException

Throws:

java.io.IOException

HttpException

getPushHandlerFactory

HandlerFactory<AsyncPushConsumer> getPushHandlerFactory()

cancel

void cancel()

abort

boolean abort()

releaseResources

void releaseResources()

appendState

void appendState(java.lang.StringBuilder buf)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object