XNIO API 3.8.13.Final · org.xnio.conduits.MessageStreamSinkConduit

Access	Constructor and Description
public	MessageStreamSinkConduit(final MessageSinkConduit the delegate conduit to set next) Construct a new instance.

Method Summary

Modifier and Type	Method and Description
public long	transferFrom(final FileChannel the file to read from src, final long the position within the file from which the transfer is to begin position, final long the number of bytes to be transferred count) Implements org.xnio.conduits.StreamSinkConduit.transferFrom. Transfer bytes into this conduit from the given file.
public long	transferFrom(final StreamSourceChannel the source to read from source, final long the number of bytes to be transferred count, final ByteBuffer the buffer to copy through. throughBuffer) Implements org.xnio.conduits.StreamSinkConduit.transferFrom. Transfers bytes from the given channel source.
public int	write(final ByteBuffer the buffer containing data to write src) Implements org.xnio.conduits.StreamSinkConduit.write. Writes a sequence of bytes to this conduit from the given buffer.
public long	write(final ByteBuffer[] the buffers containing data to write srcs, final int the offset into the buffer array offs, final int the number of buffers to write len) Implements org.xnio.conduits.StreamSinkConduit.write. Writes a sequence of bytes to this conduit from the given buffers.
public int	writeFinal(ByteBuffer The data to write src) Implements org.xnio.conduits.StreamSinkConduit.writeFinal. Writes some data to the conduit, with the same semantics as `write(java.nio.ByteBuffer)`.
public long	writeFinal(ByteBuffer[] The buffers from which bytes are to be retrieved srcs, int The offset within the buffer array of the first buffer from which bytes are to be retrieved; must be non-negative and no larger than `srcs.length` offset, int The maximum number of buffers to be accessed; must be non-negative and no larger than `srcs.length` - `offset` length) Implements org.xnio.conduits.StreamSinkConduit.writeFinal. Writes some data to the conduit, with the same semantics as `write(java.nio.ByteBuffer[], int, int)`.

Inherited from org.xnio.conduits.AbstractSinkConduit:: awaitWritable awaitWritable flush getWriteThread isWriteResumed isWriteShutdown resumeWrites setWriteReadyHandler suspendWrites terminateWrites truncateWrites wakeupWrites

MessageStreamSinkConduit	back to summary
public MessageStreamSinkConduit(final MessageSinkConduit next) Construct a new instance. Parameters next:MessageSinkConduit the delegate conduit to set

Method Detail

transferFrom	back to summary
public long transferFrom(final FileChannel src, final long position, final long count) throws IOException Implements org.xnio.conduits.StreamSinkConduit.transferFrom. Doc from org.xnio.conduits.StreamSinkConduit.transferFrom. Transfer bytes into this conduit from the given file. Parameters src:FileChannel the file to read from position:long the position within the file from which the transfer is to begin count:long the number of bytes to be transferred Returns:long the number of bytes (possibly 0) that were actually transferred Exceptions IOException: if an I/O error occurs

transferFrom

back to summary

public long transferFrom(final FileChannel src, final long position, final long count) throws IOException

Implements org.xnio.conduits.StreamSinkConduit.transferFrom.

Doc from org.xnio.conduits.StreamSinkConduit.transferFrom.

Transfer bytes into this conduit from the given file.

Parameters

src:FileChannel: the file to read from
position:long: the position within the file from which the transfer is to begin
count:long: the number of bytes to be transferred

Returns:long

the number of bytes (possibly 0) that were actually transferred

Exceptions

IOException:: if an I/O error occurs

transferFrom back to summary

transferFrom	back to summary
public long transferFrom(final StreamSourceChannel source, final long count, final ByteBuffer throughBuffer) throws IOException Implements org.xnio.conduits.StreamSinkConduit.transferFrom. Doc from org.xnio.conduits.StreamSinkConduit.transferFrom. Transfers bytes from the given channel source. On entry, `throughBuffer` will be cleared. On exit, the buffer will be flipped for emptying, and may be empty or may contain data. If this method returns a value less than `count`, then the remaining data in `throughBuffer` may contain data read from `source` which must be written to this channel to complete the operation. Parameters source:StreamSourceChannel the source to read from count:long the number of bytes to be transferred throughBuffer:ByteBuffer the buffer to copy through. Returns:long the number of bytes (possibly 0) that were actually transferred, or -1 if the end of input was reached Exceptions IOException: if an I/O error occurs

public long transferFrom(final StreamSourceChannel source, final long count, final ByteBuffer throughBuffer) throws IOException

Implements org.xnio.conduits.StreamSinkConduit.transferFrom.

Doc from org.xnio.conduits.StreamSinkConduit.transferFrom.

Transfers bytes from the given channel source. On entry, throughBuffer will be cleared. On exit, the buffer will be flipped for emptying, and may be empty or may contain data. If this method returns a value less than count, then the remaining data in throughBuffer may contain data read from source which must be written to this channel to complete the operation.

Parameters

source:StreamSourceChannel: the source to read from
count:long: the number of bytes to be transferred
throughBuffer:ByteBuffer: the buffer to copy through.

Returns:long

the number of bytes (possibly 0) that were actually transferred, or -1 if the end of input was reached

Exceptions

IOException:: if an I/O error occurs

write	back to summary
public int write(final ByteBuffer src) throws IOException Implements org.xnio.conduits.StreamSinkConduit.write. Doc from org.xnio.conduits.StreamSinkConduit.write. Writes a sequence of bytes to this conduit from the given buffer. Parameters src:ByteBuffer the buffer containing data to write Returns:int the number of bytes written, possibly 0 Exceptions IOException: if an error occurs

write

back to summary

public int write(final ByteBuffer src) throws IOException

Implements org.xnio.conduits.StreamSinkConduit.write.

Doc from org.xnio.conduits.StreamSinkConduit.write.

Writes a sequence of bytes to this conduit from the given buffer.

Parameters

src:ByteBuffer: the buffer containing data to write

Returns:int

the number of bytes written, possibly 0

Exceptions

IOException:: if an error occurs

write	back to summary
public long write(final ByteBuffer[] srcs, final int offs, final int len) throws IOException Implements org.xnio.conduits.StreamSinkConduit.write. Doc from org.xnio.conduits.StreamSinkConduit.write. Writes a sequence of bytes to this conduit from the given buffers. Parameters srcs:ByteBuffer[] the buffers containing data to write offs:int the offset into the buffer array len:int the number of buffers to write Returns:long the number of bytes written, possibly 0 Exceptions IOException: if an error occurs

write

back to summary

public long write(final ByteBuffer[] srcs, final int offs, final int len) throws IOException

Implements org.xnio.conduits.StreamSinkConduit.write.

Doc from org.xnio.conduits.StreamSinkConduit.write.

Writes a sequence of bytes to this conduit from the given buffers.

Parameters

srcs:ByteBuffer[]: the buffers containing data to write
offs:int: the offset into the buffer array
len:int: the number of buffers to write

Returns:long

the number of bytes written, possibly 0

Exceptions

IOException:: if an error occurs

writeFinal back to summary

writeFinal	back to summary
public int writeFinal(ByteBuffer src) throws IOException Implements org.xnio.conduits.StreamSinkConduit.writeFinal. Doc from org.xnio.conduits.StreamSinkConduit.writeFinal. Writes some data to the conduit, with the same semantics as `write(java.nio.ByteBuffer)`. If all the data is written out then the conduit will have its writes terminated. Semantically this method is equivalent to: `int rem = src.remaining(); int written = conduit.write(src); if(written == rem) { conduit.terminateWrites() }` Parameters src:ByteBuffer The data to write Returns:int The amount of data that was actually written. Annotations @Override

public int writeFinal(ByteBuffer src) throws IOException

Implements org.xnio.conduits.StreamSinkConduit.writeFinal.

Doc from org.xnio.conduits.StreamSinkConduit.writeFinal.

Writes some data to the conduit, with the same semantics as write(java.nio.ByteBuffer). If all the data is written out then the conduit will have its writes terminated. Semantically this method is equivalent to: int rem = src.remaining(); int written = conduit.write(src); if(written == rem) { conduit.terminateWrites() }

Parameters

src:ByteBuffer: The data to write

Returns:int

The amount of data that was actually written.

Annotations

@Override

writeFinal back to summary

writeFinal	back to summary
public long writeFinal(ByteBuffer[] srcs, int offset, int length) throws IOException Implements org.xnio.conduits.StreamSinkConduit.writeFinal. Doc from org.xnio.conduits.StreamSinkConduit.writeFinal. Writes some data to the conduit, with the same semantics as `write(java.nio.ByteBuffer[], int, int)`. If all the data is written out then the conduit will have its writes terminated. Parameters srcs:ByteBuffer[] The buffers from which bytes are to be retrieved offset:int The offset within the buffer array of the first buffer from which bytes are to be retrieved; must be non-negative and no larger than `srcs.length` length:int The maximum number of buffers to be accessed; must be non-negative and no larger than `srcs.length` - `offset` Returns:long The amount of data that was actually written Annotations @Override

public long writeFinal(ByteBuffer[] srcs, int offset, int length) throws IOException

Implements org.xnio.conduits.StreamSinkConduit.writeFinal.

Doc from org.xnio.conduits.StreamSinkConduit.writeFinal.

Writes some data to the conduit, with the same semantics as write(java.nio.ByteBuffer[], int, int). If all the data is written out then the conduit will have its writes terminated.

Parameters

srcs:ByteBuffer[]: The buffers from which bytes are to be retrieved
offset:int: The offset within the buffer array of the first buffer from which bytes are to be retrieved; must be non-negative and no larger than srcs.length
length:int: The maximum number of buffers to be accessed; must be non-negative and no larger than srcs.length - offset

Returns:long

The amount of data that was actually written

Annotations

@Override

public final Class MessageStreamSinkConduit

Constructor Summary

Method Summary

Constructor Detail

Method Detail