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
All Methods Instance Methods Concrete Methods 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()
-
-
-
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 classjava.lang.Object
-
-