io.undertow.protocols.spdy

Class SpdyStreamStreamSourceChannel

java.lang.Object

io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel<SpdyChannel,SpdyStreamSourceChannel,SpdyStreamSinkChannel>

io.undertow.protocols.spdy.SpdyStreamSourceChannel

io.undertow.protocols.spdy.SpdyStreamStreamSourceChannel

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, InterruptibleChannel, ReadableByteChannel, ScatteringByteChannel, org.xnio.channels.CloseableChannel, org.xnio.channels.Configurable, org.xnio.channels.StreamSourceChannel, org.xnio.channels.SuspendableReadChannel

Direct Known Subclasses:

SpdySynReplyStreamSourceChannel, SpdySynStreamStreamSourceChannel

public class SpdyStreamStreamSourceChannel
extends SpdyStreamSourceChannel

Author:

Stuart Douglas

Field Summary

Fields inherited from interface org.xnio.channels.Configurable

EMPTY

Method Summary

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<SpdyStreamStreamSourceChannel>	getCompletionListener()
HeaderMap	getHeaders()
int	getStreamId()
protected void	handleHeaderData(FrameHeaderData headerData)
int	read(ByteBuffer dst)
long	read(ByteBuffer[] dsts)
long	read(ByteBuffer[] dsts, int offset, int length)
void	setCompletionListener(org.xnio.ChannelListener<SpdyStreamStreamSourceChannel> completionListener)
long	transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel streamSinkChannel)
long	transferTo(long position, long count, FileChannel target)

Methods inherited from class io.undertow.protocols.spdy.SpdyStreamSourceChannel

getSpdyChannel, lastFrame

Methods inherited from class io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel

addCloseTask, awaitReadable, awaitReadable, close, dataReady, getCloseSetter, getFramedChannel, getIoThread, getMaxStreamSize, getOption, getReadFrameCount, getReadSetter, getReadThread, getWorker, isComplete, isOpen, isReadResumed, markStreamBroken, processFrameData, resumeReads, setMaxStreamSize, setOption, shutdownReads, supportsOption, suspendReads, updateFrameDataRemaining, wakeupReads

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

read

public int read(ByteBuffer dst)
         throws IOException

Specified by:

read in interface ReadableByteChannel

Overrides:

read in class AbstractFramedStreamSourceChannel<SpdyChannel,SpdyStreamSourceChannel,SpdyStreamSinkChannel>

Throws:

IOException

read

public long read(ByteBuffer[] dsts,
                 int offset,
                 int length)
          throws IOException

Specified by:

read in interface ScatteringByteChannel

Overrides:

read in class AbstractFramedStreamSourceChannel<SpdyChannel,SpdyStreamSourceChannel,SpdyStreamSinkChannel>

Throws:

IOException

read

public long read(ByteBuffer[] dsts)
          throws IOException

Specified by:

read in interface ScatteringByteChannel

Overrides:

read in class AbstractFramedStreamSourceChannel<SpdyChannel,SpdyStreamSourceChannel,SpdyStreamSinkChannel>

Throws:

IOException

transferTo

public long transferTo(long count,
                       ByteBuffer throughBuffer,
                       org.xnio.channels.StreamSinkChannel streamSinkChannel)
                throws IOException

Specified by:

transferTo in interface org.xnio.channels.StreamSourceChannel

Overrides:

transferTo in class AbstractFramedStreamSourceChannel<SpdyChannel,SpdyStreamSourceChannel,SpdyStreamSinkChannel>

Throws:

IOException

transferTo

public long transferTo(long position,
                       long count,
                       FileChannel target)
                throws IOException

Specified by:

transferTo in interface org.xnio.channels.StreamSourceChannel

Overrides:

transferTo in class AbstractFramedStreamSourceChannel<SpdyChannel,SpdyStreamSourceChannel,SpdyStreamSinkChannel>

Throws:

IOException

handleHeaderData

protected void handleHeaderData(FrameHeaderData headerData)

Overrides:

handleHeaderData in class SpdyStreamSourceChannel

complete

protected void complete()
                 throws IOException

Description copied from class: AbstractFramedStreamSourceChannel

Method that is invoked when all data has been read.

Overrides:

complete in class AbstractFramedStreamSourceChannel<SpdyChannel,SpdyStreamSourceChannel,SpdyStreamSinkChannel>

Throws:

IOException

getHeaders

public HeaderMap getHeaders()

getCompletionListener

public org.xnio.ChannelListener<SpdyStreamStreamSourceChannel> getCompletionListener()

setCompletionListener

public void setCompletionListener(org.xnio.ChannelListener<SpdyStreamStreamSourceChannel> completionListener)

channelForciblyClosed

protected void channelForciblyClosed()

Overrides:

channelForciblyClosed in class AbstractFramedStreamSourceChannel<SpdyChannel,SpdyStreamSourceChannel,SpdyStreamSinkChannel>

getStreamId

public int getStreamId()