public class AjpClientResponseStreamSourceChannel extends AbstractAjpClientStreamSourceChannel
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() |
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, String reasonPhrase, PooledByteBuffer frameData, int remaining)
public HeaderMap getHeaders()
public int getStatusCode()
public 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 IOException
AbstractFramedStreamSourceChannel
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 © 2017 JBoss by Red Hat. All rights reserved.