Class AbstractH2StreamMultiplexer.H2Stream
java.lang.Object
org.apache.hc.core5.http2.impl.nio.AbstractH2StreamMultiplexer.H2Stream
- Enclosing class:
AbstractH2StreamMultiplexer
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final AbstractH2StreamMultiplexer.H2StreamChannelImpl
private final H2StreamHandler
private final boolean
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
H2Stream
(AbstractH2StreamMultiplexer.H2StreamChannelImpl channel, H2StreamHandler handler, boolean remoteInitiated) -
Method Summary
Modifier and TypeMethodDescription(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
(package private) AtomicInteger
(package private) HandlerFactory
<AsyncPushConsumer> (package private) void
handle
(HttpException ex) (package private) boolean
(package private) boolean
(package private) boolean
(package private) boolean
(package private) boolean
(package private) boolean
(package private) void
localReset
(Exception cause, int code) (package private) void
localReset
(Exception cause, H2Error error) (package private) void
(package private) void
(package private) void
(package private) void
(package private) void
(package private) void
toString()
-
Field Details
-
channel
-
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
- Throws:
HttpException
IOException
-
consumeHeader
- Throws:
HttpException
IOException
-
consumeData
- Throws:
HttpException
IOException
-
isOutputReady
boolean isOutputReady() -
produceOutput
- Throws:
HttpException
IOException
-
produceInputCapacityUpdate
- Throws:
IOException
-
reset
-
localReset
- Throws:
IOException
-
localReset
- Throws:
IOException
-
localReset
- Throws:
IOException
-
handle
- Throws:
IOException
HttpException
-
getPushHandlerFactory
HandlerFactory<AsyncPushConsumer> getPushHandlerFactory() -
cancel
void cancel() -
abort
boolean abort() -
releaseResources
void releaseResources() -
appendState
-
toString
-