public class AjpClientResponseStreamSourceChannel extends AbstractAjpClientStreamSourceChannel
EMPTY
Constructor and Description |
---|
AjpClientResponseStreamSourceChannel(AjpClientChannel framedChannel,
HeaderMap headers,
int statusCode,
String reasonPhrase,
PooledByteBuffer frameData,
int remaining) |
Modifier and Type | Method and Description |
---|---|
protected void |
complete()
Method that is invoked when all data has been read.
|
HeaderMap |
getHeaders() |
String |
getReasonPhrase() |
int |
getStatusCode() |
protected void |
handleHeaderData(FrameHeaderData headerData) |
void |
resumeReads()
Resume reads on this channel.
|
void |
setFinishListener(ChannelListener<AjpClientResponseStreamSourceChannel> finishListener) |
void |
suspendReads()
Suspend further read notifications on this channel.
|
protected long |
updateFrameDataRemaining(PooledByteBuffer frameData,
long frameDataRemaining) |
void |
wakeupReads()
Resume reads on this channel, and force the read listener to be triggered even if the
channel isn't actually readable. |
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, String reasonPhrase, PooledByteBuffer frameData, int remaining)
public HeaderMap getHeaders()
public int getStatusCode()
public String getReasonPhrase()
public void setFinishListener(ChannelListener<AjpClientResponseStreamSourceChannel> finishListener)
protected void handleHeaderData(FrameHeaderData headerData)
protected long updateFrameDataRemaining(PooledByteBuffer frameData, long frameDataRemaining)
protected void complete() throws IOException
AbstractFramedStreamSourceChannel
public void wakeupReads()
SuspendableReadChannel
Resume reads
on this channel, and force the read listener to be triggered even if the
channel isn't actually readable.wakeupReads
in interface SuspendableReadChannel
wakeupReads
in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>
public void resumeReads()
SuspendableReadChannel
resumeReads
in interface SuspendableReadChannel
resumeReads
in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>
public void suspendReads()
SuspendableReadChannel
suspendReads
in interface SuspendableReadChannel
suspendReads
in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>
Copyright © 2019 JBoss by Red Hat. All rights reserved.