Interface H2StreamChannel
-
- All Superinterfaces:
Cancellable,CapacityChannel,DataStreamChannel,StreamChannel<java.nio.ByteBuffer>
- All Known Implementing Classes:
AbstractH2StreamMultiplexer.H2StreamChannelImpl
interface H2StreamChannel extends DataStreamChannel, CapacityChannel, Cancellable
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description intgetId()java.util.concurrent.atomic.AtomicIntegergetInputWindow()longgetLocalResetTime()java.util.concurrent.atomic.AtomicIntegergetOutputWindow()booleanisLocalClosed()default booleanisLocalReset()booleanlocalReset(int errorCode)default booleanlocalReset(H2Error error)voidmarkLocalClosed()voidpush(java.util.List<Header> headers, AsyncPushProducer pushProducer)voidsubmit(java.util.List<Header> headers, boolean endStream)default voidterminate()-
Methods inherited from interface org.apache.hc.core5.concurrent.Cancellable
cancel
-
Methods inherited from interface org.apache.hc.core5.http.nio.CapacityChannel
update
-
Methods inherited from interface org.apache.hc.core5.http.nio.DataStreamChannel
endStream, requestOutput, write
-
Methods inherited from interface org.apache.hc.core5.http.nio.StreamChannel
endStream
-
-
-
-
Method Detail
-
getId
int getId()
-
getOutputWindow
java.util.concurrent.atomic.AtomicInteger getOutputWindow()
-
getInputWindow
java.util.concurrent.atomic.AtomicInteger getInputWindow()
-
submit
void submit(java.util.List<Header> headers, boolean endStream) throws HttpException, java.io.IOException
- Throws:
HttpExceptionjava.io.IOException
-
push
void push(java.util.List<Header> headers, AsyncPushProducer pushProducer) throws HttpException, java.io.IOException
- Throws:
HttpExceptionjava.io.IOException
-
isLocalClosed
boolean isLocalClosed()
-
markLocalClosed
void markLocalClosed()
-
localReset
boolean localReset(int errorCode) throws java.io.IOException- Throws:
java.io.IOException
-
localReset
default boolean localReset(H2Error error) throws java.io.IOException
- Throws:
java.io.IOException
-
terminate
default void terminate()
-
getLocalResetTime
long getLocalResetTime()
-
isLocalReset
default boolean isLocalReset()
-
-