public class PreChunkedStreamSinkConduit
extends org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
Constructor | Description |
---|---|
PreChunkedStreamSinkConduit(org.xnio.conduits.StreamSinkConduit next,
ConduitListener<? super PreChunkedStreamSinkConduit> finishListener,
Attachable attachable) |
Construct a new instance.
|
Modifier and Type | Method | Description |
---|---|---|
void |
awaitWritable() |
|
void |
awaitWritable(long time,
TimeUnit timeUnit) |
|
boolean |
flush() |
|
void |
terminateWrites() |
|
long |
transferFrom(FileChannel src,
long position,
long count) |
|
long |
transferFrom(org.xnio.channels.StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
|
int |
write(ByteBuffer src) |
|
long |
write(ByteBuffer[] srcs,
int offset,
int length) |
|
int |
writeFinal(ByteBuffer src) |
|
long |
writeFinal(ByteBuffer[] srcs,
int offset,
int length) |
getWriteThread, isWriteResumed, isWriteShutdown, resumeWrites, setWriteReadyHandler, suspendWrites, truncateWrites, wakeupWrites
public PreChunkedStreamSinkConduit(org.xnio.conduits.StreamSinkConduit next, ConduitListener<? super PreChunkedStreamSinkConduit> finishListener, Attachable attachable)
next
- the channel to wrapfinishListener
- The finish listenerattachable
- The attachablepublic int write(ByteBuffer src) throws IOException
write
in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
IOException
public long write(ByteBuffer[] srcs, int offset, int length) throws IOException
write
in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
IOException
public long writeFinal(ByteBuffer[] srcs, int offset, int length) throws IOException
writeFinal
in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
IOException
public int writeFinal(ByteBuffer src) throws IOException
writeFinal
in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
IOException
public long transferFrom(FileChannel src, long position, long count) throws IOException
transferFrom
in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
IOException
public long transferFrom(org.xnio.channels.StreamSourceChannel source, long count, ByteBuffer throughBuffer) throws IOException
transferFrom
in class org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
IOException
public boolean flush() throws IOException
flush
in class org.xnio.conduits.AbstractSinkConduit<org.xnio.conduits.StreamSinkConduit>
IOException
public void terminateWrites() throws IOException
terminateWrites
in class org.xnio.conduits.AbstractSinkConduit<org.xnio.conduits.StreamSinkConduit>
IOException
public void awaitWritable() throws IOException
awaitWritable
in class org.xnio.conduits.AbstractSinkConduit<org.xnio.conduits.StreamSinkConduit>
IOException
public void awaitWritable(long time, TimeUnit timeUnit) throws IOException
awaitWritable
in class org.xnio.conduits.AbstractSinkConduit<org.xnio.conduits.StreamSinkConduit>
IOException
Copyright © 2018. All rights reserved.