public class Http2StreamSourceChannel extends AbstractHttp2StreamSourceChannel implements Http2Stream
| Modifier and Type | Method and 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() |
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) |
String | toString() |
long | transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel streamSinkChannel) |
long | transferTo(long position, long count, FileChannel target) |
getFramedChannel, getHttp2Channel, lastFrameaddCloseTask, awaitReadable, awaitReadable, close, dataReady, getCloseSetter, getIoThread, getMaxStreamSize, getOption, getReadFrameCount, getReadSetter, getReadThread, getWorker, isComplete, isOpen, isReadResumed, markStreamBroken, processFrameData, resumeReads, setMaxStreamSize, setOption, shutdownReads, supportsOption, suspendReads, updateFrameDataRemaining, wakeupReadsprotected void handleHeaderData(FrameHeaderData headerData)
handleHeaderData in class AbstractHttp2StreamSourceChannelpublic Http2HeadersStreamSinkChannel getResponseChannel()
public int read(ByteBuffer dst) throws IOException
read in interface ReadableByteChannelread in class AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>IOExceptionpublic long read(ByteBuffer[] dsts, int offset, int length) throws IOException
read in interface ScatteringByteChannelread in class AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>IOExceptionpublic long read(ByteBuffer[] dsts) throws IOException
read in interface ScatteringByteChannelread in class AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>IOExceptionpublic long transferTo(long count,
ByteBuffer throughBuffer,
org.xnio.channels.StreamSinkChannel streamSinkChannel)
throws IOException transferTo in interface org.xnio.channels.StreamSourceChanneltransferTo in class AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>IOExceptionpublic long transferTo(long position,
long count,
FileChannel target)
throws IOException transferTo in interface org.xnio.channels.StreamSourceChanneltransferTo in class AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>IOExceptionprotected void complete()
throws IOException AbstractFramedStreamSourceChannelcomplete in class AbstractFramedStreamSourceChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>IOExceptionpublic 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 Http2StreamCopyright © 2015 JBoss by Red Hat. All rights reserved.