Module id.ICE

Package id.ICE.handlers

Class MessageReceiver

Object

MessageReceiver

All Implemented Interfaces:

CompletionHandler<Integer,AsynchronousSocketChannel>

public class MessageReceiver
extends Object
implements CompletionHandler<Integer,AsynchronousSocketChannel>

This handler acts as a message receiver and is notified each time server reads some data from the client.

All read requests are done asynchronously. It means that this receiver may be called with different amounts of data read each time.

Receiver relies on message scanner to extract a message from a stream of bytes and then it passes them back to the looper.

Each time receiver reads new portion of data it appends it to internal buffer and then it uses scanner to tell where message ends in this buffer and another begins.

Constructor Summary

Constructors

Constructor	Description
MessageReceiver(AsynchronousSocketChannel channel, MessageScanner scanner)
MessageReceiver(AsynchronousSocketChannel channel, MessageScanner scanner, int bufSize)

Method Summary

Modifier and Type	Method	Description
void	completed(Integer result, AsynchronousSocketChannel channel)	Called once read operation succeeds with some data read or when read is failed.
void	failed(Throwable exc, AsynchronousSocketChannel channel)
CompletableFuture<ByteBuffer>	receive()

Methods inherited from class Object

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

Constructor Details

MessageReceiver

public MessageReceiver(AsynchronousSocketChannel channel,
 MessageScanner scanner)

MessageReceiver

public MessageReceiver(AsynchronousSocketChannel channel,
 MessageScanner scanner,
 int bufSize)

Method Details

completed

public void completed(Integer result,
 AsynchronousSocketChannel channel)

Called once read operation succeeds with some data read or when read is failed.

Specified by:

completed in interface CompletionHandler<Integer,AsynchronousSocketChannel>

failed

public void failed(Throwable exc,
 AsynchronousSocketChannel channel)

Specified by:

failed in interface CompletionHandler<Integer,AsynchronousSocketChannel>

receive

public CompletableFuture<ByteBuffer> receive()