Package io.undertow.protocols.http2
Class Http2StreamSourceChannel
java.lang.Object
io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>
io.undertow.protocols.http2.AbstractHttp2StreamSourceChannel
io.undertow.protocols.http2.Http2StreamSourceChannel
- All Implemented Interfaces:
Http2Stream
,Closeable
,AutoCloseable
,Channel
,InterruptibleChannel
,ReadableByteChannel
,ScatteringByteChannel
,org.xnio.channels.CloseableChannel
,org.xnio.channels.Configurable
,org.xnio.channels.StreamSourceChannel
,org.xnio.channels.SuspendableReadChannel
public class Http2StreamSourceChannel
extends AbstractHttp2StreamSourceChannel
implements Http2Stream
- Author:
- Stuart Douglas
-
Nested Class Summary
Nested Classes -
Field Summary
Fields inherited from interface org.xnio.channels.Configurable
EMPTY
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
protected void
complete()
Method that is invoked when all data has been read.org.xnio.ChannelListener<Http2StreamSourceChannel>
int
protected void
handleHeaderData
(FrameHeaderData headerData) boolean
int
read
(ByteBuffer dst) long
read
(ByteBuffer[] dsts) long
read
(ByteBuffer[] dsts, int offset, int length) void
setCompletionListener
(org.xnio.ChannelListener<Http2StreamSourceChannel> completionListener) void
setIgnoreForceClose
(boolean ignoreForceClose) void
setTrailersHandler
(Http2StreamSourceChannel.TrailersHandler trailersHandler) toString()
long
transferTo
(long position, long count, FileChannel target) long
transferTo
(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel streamSinkChannel) protected long
updateFrameDataRemaining
(PooledByteBuffer data, long frameDataRemaining) Methods inherited from class io.undertow.protocols.http2.AbstractHttp2StreamSourceChannel
getFramedChannel, getHttp2Channel, lastFrame, markStreamBroken
Methods inherited from class io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel
addCloseTask, awaitReadable, awaitReadable, close, dataReady, getCloseSetter, getIoThread, getMaxStreamSize, getOption, getReadFrameCount, getReadSetter, getReadThread, getWorker, isComplete, isLastFrame, isOpen, isReadResumed, processFrameData, resumeReads, setMaxStreamSize, setOption, shutdownReads, supportsOption, suspendReads, wakeupReads
-
Method Details
-
handleHeaderData
- Overrides:
handleHeaderData
in classAbstractHttp2StreamSourceChannel
-
updateFrameDataRemaining
-
getResponseChannel
-
read
- Specified by:
read
in interfaceReadableByteChannel
- Overrides:
read
in classAbstractFramedStreamSourceChannel<Http2Channel,
AbstractHttp2StreamSourceChannel, AbstractHttp2StreamSinkChannel> - Throws:
IOException
-
read
- Specified by:
read
in interfaceScatteringByteChannel
- Overrides:
read
in classAbstractFramedStreamSourceChannel<Http2Channel,
AbstractHttp2StreamSourceChannel, AbstractHttp2StreamSinkChannel> - Throws:
IOException
-
read
- Specified by:
read
in interfaceScatteringByteChannel
- Overrides:
read
in classAbstractFramedStreamSourceChannel<Http2Channel,
AbstractHttp2StreamSourceChannel, AbstractHttp2StreamSinkChannel> - Throws:
IOException
-
transferTo
public long transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel streamSinkChannel) throws IOException - Specified by:
transferTo
in interfaceorg.xnio.channels.StreamSourceChannel
- Overrides:
transferTo
in classAbstractFramedStreamSourceChannel<Http2Channel,
AbstractHttp2StreamSourceChannel, AbstractHttp2StreamSinkChannel> - Throws:
IOException
-
transferTo
- Specified by:
transferTo
in interfaceorg.xnio.channels.StreamSourceChannel
- Overrides:
transferTo
in classAbstractFramedStreamSourceChannel<Http2Channel,
AbstractHttp2StreamSourceChannel, AbstractHttp2StreamSinkChannel> - Throws:
IOException
-
complete
Description copied from class:AbstractFramedStreamSourceChannel
Method that is invoked when all data has been read.- Overrides:
complete
in classAbstractFramedStreamSourceChannel<Http2Channel,
AbstractHttp2StreamSourceChannel, AbstractHttp2StreamSinkChannel> - Throws:
IOException
-
getHeaders
-
getCompletionListener
-
setCompletionListener
public void setCompletionListener(org.xnio.ChannelListener<Http2StreamSourceChannel> completionListener) -
channelForciblyClosed
protected void channelForciblyClosed() -
setIgnoreForceClose
public void setIgnoreForceClose(boolean ignoreForceClose) -
isIgnoreForceClose
public boolean isIgnoreForceClose() -
getStreamId
public int getStreamId()- Specified by:
getStreamId
in interfaceHttp2Stream
-
getTrailersHandler
-
setTrailersHandler
-
toString
-