java.io.Closeable
, java.lang.AutoCloseable
, java.nio.channels.Channel
, java.nio.channels.InterruptibleChannel
, java.nio.channels.ReadableByteChannel
, java.nio.channels.ScatteringByteChannel
, org.xnio.channels.CloseableChannel
, org.xnio.channels.Configurable
, org.xnio.channels.StreamSourceChannel
, org.xnio.channels.SuspendableReadChannel
public class AjpClientResponseStreamSourceChannel extends AbstractAjpClientStreamSourceChannel
Constructor | Description |
---|---|
AjpClientResponseStreamSourceChannel(AjpClientChannel framedChannel,
HeaderMap headers,
int statusCode,
java.lang.String reasonPhrase,
PooledByteBuffer frameData,
int remaining) |
Modifier and Type | Method | Description |
---|---|---|
protected void |
complete() |
Method that is invoked when all data has been read.
|
HeaderMap |
getHeaders() |
|
java.lang.String |
getReasonPhrase() |
|
int |
getStatusCode() |
|
protected void |
handleHeaderData(FrameHeaderData headerData) |
|
void |
resumeReads() |
|
void |
setFinishListener(org.xnio.ChannelListener<AjpClientResponseStreamSourceChannel> finishListener) |
|
void |
suspendReads() |
|
protected long |
updateFrameDataRemaining(PooledByteBuffer frameData,
long frameDataRemaining) |
|
void |
wakeupReads() |
addCloseTask, awaitReadable, awaitReadable, channelForciblyClosed, close, dataReady, getCloseSetter, getFramedChannel, getIoThread, getMaxStreamSize, getOption, getReadFrameCount, getReadSetter, getReadThread, getWorker, isComplete, isLastFrame, isOpen, isReadResumed, lastFrame, markStreamBroken, processFrameData, read, read, read, setMaxStreamSize, setOption, shutdownReads, supportsOption, transferTo, transferTo
public AjpClientResponseStreamSourceChannel(AjpClientChannel framedChannel, HeaderMap headers, int statusCode, java.lang.String reasonPhrase, PooledByteBuffer frameData, int remaining)
public HeaderMap getHeaders()
public int getStatusCode()
public java.lang.String getReasonPhrase()
public void setFinishListener(org.xnio.ChannelListener<AjpClientResponseStreamSourceChannel> finishListener)
protected void handleHeaderData(FrameHeaderData headerData)
protected long updateFrameDataRemaining(PooledByteBuffer frameData, long frameDataRemaining)
protected void complete() throws java.io.IOException
AbstractFramedStreamSourceChannel
complete
in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>
java.io.IOException
public void wakeupReads()
wakeupReads
in interface org.xnio.channels.SuspendableReadChannel
wakeupReads
in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>
public void resumeReads()
resumeReads
in interface org.xnio.channels.SuspendableReadChannel
resumeReads
in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>
public void suspendReads()
suspendReads
in interface org.xnio.channels.SuspendableReadChannel
suspendReads
in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>
Copyright © 2018. All rights reserved.