com.vanillasource.aio.channel

Class ByteArrayReadableByteChannelSlave

java.lang.Object

com.vanillasource.aio.channel.ByteArrayReadableByteChannelSlave

All Implemented Interfaces:

AioSlave<byte[]>

public class ByteArrayReadableByteChannelSlave
extends Object
implements AioSlave<byte[]>

Reads all bytes into an internal buffer. Note, this has to copy the bytes multiple times, and consumes as much memory as all the bytes. Use only when the size of the input is limited/known.

Constructor Summary

Constructors

Constructor and Description
ByteArrayReadableByteChannelSlave(ReadableByteChannel channel)
ByteArrayReadableByteChannelSlave(ReadableByteChannel channel, int initialSize)

Method Summary

Modifier and Type	Method and Description
byte[]	onCompleted() Called by the leader to indicate that the I/O conversation completed.
void	onReady() Slave is notified by the leader to read or write data.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ByteArrayReadableByteChannelSlave

public ByteArrayReadableByteChannelSlave(ReadableByteChannel channel,
                                         int initialSize)

ByteArrayReadableByteChannelSlave

public ByteArrayReadableByteChannelSlave(ReadableByteChannel channel)

Method Detail

onReady

public void onReady()

Description copied from interface: AioSlave

Slave is notified by the leader to read or write data. I/O is only allowed during this method call.

Specified by:

onReady in interface AioSlave<byte[]>

onCompleted

public byte[] onCompleted()

Description copied from interface: AioSlave

Called by the leader to indicate that the I/O conversation completed. There will be no more calls to onReady().

Specified by:

onCompleted in interface AioSlave<byte[]>

Returns:

An object that is either the result of reading the data, or an object indicating completion of writing all data.