public abstract class SpdyStreamStreamSinkChannel extends SpdyStreamSinkChannel
Modifier and Type | Method and Description |
---|---|
protected org.xnio.Pooled<ByteBuffer>[] |
allocateAll(org.xnio.Pooled<ByteBuffer>[] allHeaderBuffers,
org.xnio.Pooled<ByteBuffer> currentBuffer) |
protected void |
channelForciblyClosed()
Called when a channel has been forcibly closed, and data (frames) have already been written.
|
protected SendFrameHeader |
createFrameHeader() |
protected abstract SendFrameHeader |
createFrameHeaderImpl() |
protected org.xnio.Pooled<ByteBuffer>[] |
createHeaderBlock(org.xnio.Pooled<ByteBuffer> firstHeaderBuffer,
org.xnio.Pooled<ByteBuffer>[] allHeaderBuffers,
ByteBuffer firstBuffer,
HeaderMap headers) |
protected abstract Deflater |
getDeflater() |
int |
getStreamId() |
protected int |
grabFlowControlBytes(int toSend)
This method should be called before sending.
|
protected void |
handleFlushComplete(boolean finalFrame) |
isLastFrame
awaitWritable, awaitWritable, close, createFrameFooter, flush, getBuffer, getChannel, getCloseSetter, getIoThread, getOption, getWorker, getWriteSetter, getWriteThread, isBroken, isFinalFrameQueued, isFirstDataWritten, isOpen, isReadyForFlush, isWriteResumed, isWritesShutdown, markBroken, resumeWrites, resumeWritesInternal, setOption, shutdownWrites, supportsOption, suspendWrites, transferFrom, transferFrom, wakeupWrites, write, write, write, writeFinal, writeFinal, writeFinal
public int getStreamId()
protected void channelForciblyClosed() throws IOException
AbstractFramedStreamSinkChannel
channelForciblyClosed
in class AbstractFramedStreamSinkChannel<SpdyChannel,SpdyStreamSourceChannel,SpdyStreamSinkChannel>
IOException
protected final SendFrameHeader createFrameHeader()
protected void handleFlushComplete(boolean finalFrame)
protected org.xnio.Pooled<ByteBuffer>[] createHeaderBlock(org.xnio.Pooled<ByteBuffer> firstHeaderBuffer, org.xnio.Pooled<ByteBuffer>[] allHeaderBuffers, ByteBuffer firstBuffer, HeaderMap headers)
protected abstract SendFrameHeader createFrameHeaderImpl()
protected int grabFlowControlBytes(int toSend)
protected abstract Deflater getDeflater()
protected org.xnio.Pooled<ByteBuffer>[] allocateAll(org.xnio.Pooled<ByteBuffer>[] allHeaderBuffers, org.xnio.Pooled<ByteBuffer> currentBuffer)
Copyright © 2016 JBoss by Red Hat. All rights reserved.