org.neo.swarm.util.network.tcp
Class ObjectReader

java.lang.Object
  org.neo.swarm.util.network.tcp.ObjectReader

All Implemented Interfaces:

java.lang.Runnable

public class ObjectReader

extends java.lang.Object

implements java.lang.Runnable

Sets up some packet, buffer streams to work with NBIO sockets.

Author:

navery

Constructor Summary

ObjectReader(java.nio.channels.SocketChannel channel, java.nio.channels.Selector selector, ListenCallback callback, int bufferSize)

Method Summary

boolean	read() Drain the channel
void	run() Called in the context of a threadpool

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectReader

public ObjectReader(java.nio.channels.SocketChannel channel,
                    java.nio.channels.Selector selector,
                    ListenCallback callback,
                    int bufferSize)

Method Detail

run

public void run()

Called in the context of a threadpool

Specified by:

run in interface java.lang.Runnable

read

public boolean read()

Drain the channel

Returns: