ds.funnel.data.channel

Class ChannelReader

java.lang.Object

ds.funnel.node.task.Task<T>

ds.funnel.node.task.ScheduledTask<T>

ds.funnel.node.task.SelectableTask<java.lang.Void>

ds.funnel.data.channel.ChannelReader

All Implemented Interfaces:

java.lang.Runnable

public class ChannelReader
extends SelectableTask<java.lang.Void>

ChannelReader.java: Reads bytes from a channel. This is non-blocking.

Author:

Ryan Stern

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.concurrent.LinkedBlockingQueue<java.lang.Integer>	logReader
static int	RECV_BUFFER_SIZE

Fields inherited from class ds.funnel.node.task.Task

AUTOSTART, IGNORENULL, RUNONCE

Constructor Summary

Constructors

Constructor and Description
ChannelReader(java.nio.channels.ReadableByteChannel inChannel, ChannelManager inManager) Creates a reader task for this channel.

Method Summary

Methods inherited from class ds.funnel.node.task.SelectableTask

cancel, startTaskSelect, startTaskSelectOnce

Methods inherited from class ds.funnel.node.task.ScheduledTask

startTaskAsync, startTaskLater, startTaskTimer

Methods inherited from class ds.funnel.node.task.Task

chainTask, getResult, getResult, getResultNow, isCancelled, run, startTask

Methods inherited from class java.lang.Object

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

Field Detail

RECV_BUFFER_SIZE

public static final int RECV_BUFFER_SIZE

See Also:

Constant Field Values

logReader

public static java.util.concurrent.LinkedBlockingQueue<java.lang.Integer> logReader

Constructor Detail

ChannelReader

public ChannelReader(java.nio.channels.ReadableByteChannel inChannel,
                     ChannelManager inManager)

Creates a reader task for this channel.

Parameters:

inChannel - - The channel being read from.

inFormat - - The format of the data being read.