Http2Stream
public class Http2StreamSourceChannel extends AbstractHttp2StreamSourceChannel implements Http2Stream
Modifier and Type | Class | Description |
---|---|---|
static interface |
Http2StreamSourceChannel.TrailersHandler |
Modifier and Type | Method | Description |
---|---|---|
protected void |
channelForciblyClosed() |
|
protected void |
complete() |
Method that is invoked when all data has been read.
|
org.xnio.ChannelListener<Http2StreamSourceChannel> |
getCompletionListener() |
|
HeaderMap |
getHeaders() |
|
Http2HeadersStreamSinkChannel |
getResponseChannel() |
|
int |
getStreamId() |
|
Http2StreamSourceChannel.TrailersHandler |
getTrailersHandler() |
|
protected void |
handleHeaderData(FrameHeaderData headerData) |
|
boolean |
isIgnoreForceClose() |
|
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) |
|
String |
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) |
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
getFramedChannel, getHttp2Channel, lastFrame, markStreamBroken
protected void handleHeaderData(FrameHeaderData headerData)
handleHeaderData
in class AbstractHttp2StreamSourceChannel
protected long updateFrameDataRemaining(PooledByteBuffer data, long frameDataRemaining)
public Http2HeadersStreamSinkChannel getResponseChannel()
public int read(ByteBuffer dst) throws IOException
read
in class AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>
IOException
public long read(ByteBuffer[] dsts, int offset, int length) throws IOException
read
in class AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>
IOException
public long read(ByteBuffer[] dsts) throws IOException
read
in class AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>
IOException
public long transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel streamSinkChannel) throws IOException
transferTo
in class AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>
IOException
public long transferTo(long position, long count, FileChannel target) throws IOException
transferTo
in class AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>
IOException
protected void complete() throws IOException
AbstractFramedStreamSourceChannel
complete
in class AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>
IOException
public HeaderMap getHeaders()
public org.xnio.ChannelListener<Http2StreamSourceChannel> getCompletionListener()
public void setCompletionListener(org.xnio.ChannelListener<Http2StreamSourceChannel> completionListener)
protected void channelForciblyClosed()
public void setIgnoreForceClose(boolean ignoreForceClose)
public boolean isIgnoreForceClose()
public int getStreamId()
getStreamId
in interface Http2Stream
public Http2StreamSourceChannel.TrailersHandler getTrailersHandler()
public void setTrailersHandler(Http2StreamSourceChannel.TrailersHandler trailersHandler)
Copyright © 2018. All rights reserved.