com.robopupu.api.graph.nodes

Class ListNode<IN>

java.lang.Object

com.robopupu.api.graph.Node<IN,IN>

com.robopupu.api.graph.nodes.ListNode<IN>

All Implemented Interfaces:

InputNode<IN>, OutputNode<IN>

public class ListNode<IN>
extends Node<IN,IN>

ListNode either emits all the values from a given List (immutable version), or the input values that are received and stored to a List until Node.onCompleted(OutputNode) is invoked (mutable version).

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.ArrayList<IN>	list
protected boolean	mutableList

Fields inherited from class com.robopupu.api.graph.Node

graph, inputNodes

Constructor Summary

Constructors

Constructor and Description
ListNode()
ListNode(java.util.List<IN> list)

Method Summary

Modifier and Type	Method and Description
protected void	doOnReset() Invoked by InputNode.onCompleted(OutputNode).
void	emitOutput() Invoked to emit the contents of this ListNode.
java.util.List<IN>	getList()
void	onCompleted(OutputNode<?> source) Invoked when the specified source OutputNode is completed.
protected IN	processInput(OutputNode<IN> source, IN input) Invoked by InputNode.onInput(OutputNode, Object) when the given input Object has been received from the OutputNode that emitted it.

Methods inherited from class com.robopupu.api.graph.Node

action, action, addInputNode, attach, begin, begin, beginTimer, beginTimer, buffer, completed, concat, concatStrings, count, createErrorMessage, detach, dispatchError, dispatchReset, distinct, doOnCompleted, doOnError, doOnInput, emitOutput, filter, first, first, getGraph, hasInputNodes, isErrorReceived, last, last, map, merge, nth, observer, observer, onAttached, onDetached, onError, onInput, onReset, removeInputNode, repeat, reverse, setErrorReceived, setGraph, skip, skipWhile, start, string, sum, take, timer, timer, toBoolean, toByte, toChar, toDouble, toFloat, toInt, toLong, toMain, toShort, toWorker, whenClicked, whenTextChanged

Methods inherited from class java.lang.Object

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

Field Detail

list

protected java.util.ArrayList<IN> list

mutableList

protected boolean mutableList

Constructor Detail

ListNode

public ListNode()

ListNode

public ListNode(java.util.List<IN> list)

Method Detail

getList

public java.util.List<IN> getList()

processInput

protected IN processInput(OutputNode<IN> source,
                          IN input)

Description copied from class: Node

Invoked by InputNode.onInput(OutputNode, Object) when the given input Object has been received from the OutputNode that emitted it.

Overrides:

processInput in class Node<IN,IN>

Parameters:

source - An OutputNode that emitted the input.

input - The input Object.

emitOutput

public void emitOutput()

Invoked to emit the contents of this ListNode.

Specified by:

emitOutput in interface OutputNode<IN>

Overrides:

emitOutput in class Node<IN,IN>

doOnReset

protected void doOnReset()

Description copied from class: Node

Invoked by InputNode.onCompleted(OutputNode). This method can be overridden in subclasses for hooking on the reset events.

Overrides:

doOnReset in class Node<IN,IN>

onCompleted

public void onCompleted(OutputNode<?> source)

Description copied from interface: InputNode

Invoked when the specified source OutputNode is completed.

Specified by:

onCompleted in interface InputNode<IN>

Overrides:

onCompleted in class Node<IN,IN>

Parameters:

source - The completed OutputNode.