public class ChunkedStreamSourceConduit
extends org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
Modifier and Type | Field and Description |
---|---|
static AttachmentKey<HeaderMap> |
TRAILERS
Deprecated.
|
Modifier | Constructor and Description |
---|---|
protected |
ChunkedStreamSourceConduit(org.xnio.conduits.StreamSourceConduit next,
io.undertow.conduits.ChunkedStreamSourceConduit.BufferWrapper bufferWrapper,
ConduitListener<? super ChunkedStreamSourceConduit> finishListener,
Attachable attachable,
HttpServerExchange exchange) |
|
ChunkedStreamSourceConduit(org.xnio.conduits.StreamSourceConduit next,
HttpServerExchange exchange,
ConduitListener<? super ChunkedStreamSourceConduit> finishListener) |
|
ChunkedStreamSourceConduit(org.xnio.conduits.StreamSourceConduit next,
org.xnio.conduits.PushBackStreamSourceConduit channel,
org.xnio.Pool<ByteBuffer> pool,
ConduitListener<? super ChunkedStreamSourceConduit> finishListener,
Attachable attachable) |
Modifier and Type | Method and Description |
---|---|
boolean |
isFinished() |
int |
read(ByteBuffer dst) |
long |
read(ByteBuffer[] dsts,
int offset,
int length) |
void |
terminateReads() |
long |
transferTo(long count,
ByteBuffer throughBuffer,
org.xnio.channels.StreamSinkChannel target) |
long |
transferTo(long position,
long count,
FileChannel target) |
awaitReadable, awaitReadable, getReadThread, isReadResumed, isReadShutdown, resumeReads, setReadReadyHandler, suspendReads, wakeupReads
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
@Deprecated public static final AttachmentKey<HeaderMap> TRAILERS
public ChunkedStreamSourceConduit(org.xnio.conduits.StreamSourceConduit next, org.xnio.conduits.PushBackStreamSourceConduit channel, org.xnio.Pool<ByteBuffer> pool, ConduitListener<? super ChunkedStreamSourceConduit> finishListener, Attachable attachable)
public ChunkedStreamSourceConduit(org.xnio.conduits.StreamSourceConduit next, HttpServerExchange exchange, ConduitListener<? super ChunkedStreamSourceConduit> finishListener)
protected ChunkedStreamSourceConduit(org.xnio.conduits.StreamSourceConduit next, io.undertow.conduits.ChunkedStreamSourceConduit.BufferWrapper bufferWrapper, ConduitListener<? super ChunkedStreamSourceConduit> finishListener, Attachable attachable, HttpServerExchange exchange)
public long transferTo(long position, long count, FileChannel target) throws IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
transferTo
in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
IOException
public long transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) throws IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
transferTo
in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
IOException
public long read(ByteBuffer[] dsts, int offset, int length) throws IOException
read
in interface org.xnio.conduits.StreamSourceConduit
read
in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
IOException
public void terminateReads() throws IOException
terminateReads
in interface org.xnio.conduits.SourceConduit
terminateReads
in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
IOException
public int read(ByteBuffer dst) throws IOException
read
in interface org.xnio.conduits.StreamSourceConduit
read
in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
IOException
public boolean isFinished()
Copyright © 2014 JBoss by Red Hat. All rights reserved.