Http2Stream
, java.io.Closeable
, java.lang.AutoCloseable
, java.nio.channels.Channel
, java.nio.channels.GatheringByteChannel
, java.nio.channels.InterruptibleChannel
, java.nio.channels.WritableByteChannel
, org.xnio.channels.CloseableChannel
, org.xnio.channels.Configurable
, org.xnio.channels.StreamSinkChannel
, org.xnio.channels.SuspendableWriteChannel
Http2HeadersStreamSinkChannel
, Http2PushPromiseStreamSinkChannel
public class Http2DataStreamSinkChannel extends Http2StreamSinkChannel implements Http2Stream
Modifier and Type | Class | Description |
---|---|---|
static interface |
Http2DataStreamSinkChannel.TrailersProducer |
Modifier and Type | Method | Description |
---|---|---|
protected void |
channelForciblyClosed() |
Called when a channel has been forcibly closed, and data (frames) have already been written.
|
protected SendFrameHeader |
createFrameHeaderImpl() |
|
boolean |
flush() |
|
org.xnio.ChannelListener<Http2DataStreamSinkChannel> |
getCompletionListener() |
|
HeaderMap |
getHeaders() |
|
Http2DataStreamSinkChannel.TrailersProducer |
getTrailersProducer() |
|
protected void |
handleFlushComplete(boolean finalFrame) |
|
protected boolean |
isFlushRequiredOnEmptyBuffer() |
|
void |
setCompletionListener(org.xnio.ChannelListener<Http2DataStreamSinkChannel> completionListener) |
|
void |
setTrailersProducer(Http2DataStreamSinkChannel.TrailersProducer trailersProducer) |
|
protected void |
writeBeforeHeaderBlock(java.nio.ByteBuffer buffer) |
awaitWritable, awaitWritable, close, getBuffer, getChannel, getCloseSetter, getIoThread, getOption, getWorker, getWriteSetter, getWriteThread, isBroken, isBufferFull, isFinalFrameQueued, isFirstDataWritten, isOpen, isReadyForFlush, isWriteResumed, isWritesShutdown, markBroken, preWriteTransform, resumeWrites, resumeWritesInternal, safeToSend, send, sendInternal, setOption, shutdownWrites, supportsOption, suspendWrites, transferFrom, transferFrom, wakeupWrites, write, write, write, writeFinal, writeFinal, writeFinal
isLastFrame
getStreamId
allocateAll, createFrameHeader, getStreamId, grabFlowControlBytes
public Http2DataStreamSinkChannel.TrailersProducer getTrailersProducer()
public void setTrailersProducer(Http2DataStreamSinkChannel.TrailersProducer trailersProducer)
protected SendFrameHeader createFrameHeaderImpl()
createFrameHeaderImpl
in class Http2StreamSinkChannel
public boolean flush() throws java.io.IOException
flush
in interface org.xnio.channels.SuspendableWriteChannel
flush
in class AbstractFramedStreamSinkChannel<Http2Channel,AbstractHttp2StreamSourceChannel,AbstractHttp2StreamSinkChannel>
java.io.IOException
protected void writeBeforeHeaderBlock(java.nio.ByteBuffer buffer)
protected boolean isFlushRequiredOnEmptyBuffer()
public HeaderMap getHeaders()
protected void handleFlushComplete(boolean finalFrame)
handleFlushComplete
in class Http2StreamSinkChannel
protected void channelForciblyClosed() throws java.io.IOException
AbstractFramedStreamSinkChannel
channelForciblyClosed
in class Http2StreamSinkChannel
java.io.IOException
public org.xnio.ChannelListener<Http2DataStreamSinkChannel> getCompletionListener()
public void setCompletionListener(org.xnio.ChannelListener<Http2DataStreamSinkChannel> completionListener)
Copyright © 2018. All rights reserved.