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, Closeable closeable) |
| ChunkedStreamSourceConduit(org.xnio.conduits.StreamSourceConduit next, HttpServerExchange exchange, ConduitListener<? super ChunkedStreamSourceConduit> finishListener) |
| ChunkedStreamSourceConduit(org.xnio.conduits.StreamSourceConduit next, org.xnio.conduits.PushBackStreamSourceConduit channel, ByteBufferPool pool, ConduitListener<? super ChunkedStreamSourceConduit> finishListener, Attachable attachable, Closeable closeable) |
| 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, wakeupReadsclone, 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,
ByteBufferPool pool,
ConduitListener<? super ChunkedStreamSourceConduit> finishListener,
Attachable attachable,
Closeable closeable) 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,
Closeable closeable) public long transferTo(long position,
long count,
FileChannel target)
throws IOException transferTo in interface org.xnio.conduits.StreamSourceConduittransferTo in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>IOExceptionpublic long transferTo(long count,
ByteBuffer throughBuffer,
org.xnio.channels.StreamSinkChannel target)
throws IOException transferTo in interface org.xnio.conduits.StreamSourceConduittransferTo in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>IOExceptionpublic long read(ByteBuffer[] dsts, int offset, int length) throws IOException
read in interface org.xnio.conduits.StreamSourceConduitread in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>IOExceptionpublic void terminateReads()
throws IOException terminateReads in interface org.xnio.conduits.SourceConduitterminateReads in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>IOExceptionpublic int read(ByteBuffer dst) throws IOException
read in interface org.xnio.conduits.StreamSourceConduitread in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>IOExceptionpublic boolean isFinished()
Copyright © 2020 JBoss by Red Hat. All rights reserved.