com.robopupu.api.graph.nodes

Class ConcatNode<IN>

java.lang.Object

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

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

All Implemented Interfaces:

InputNode<IN>, OutputNode<IN>

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

ConcatNode takes any number of OutputNodes and emits the input values received from them one after the other, without interleaving the values.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.ArrayList[]	buffers
protected boolean[]	completed
protected int	mCompletedIndex
protected java.util.HashMap<OutputNode,java.lang.Integer>	sourceIndeces
protected OutputNode<IN>[]	sources
protected int	sourcesCount

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

graph, inputNodes

Constructor Summary

Constructors

Constructor and Description
ConcatNode(OutputNode<IN>... sources)

Method Summary

Modifier and Type	Method and Description
void	emitBufferedValuesFor(int index)
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, doOnReset, emitOutput, 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

buffers

protected final java.util.ArrayList[] buffers

completed

protected final boolean[] completed

sourcesCount

protected final int sourcesCount

sourceIndeces

protected final java.util.HashMap<OutputNode,java.lang.Integer> sourceIndeces

sources

protected final OutputNode<IN>[] sources

mCompletedIndex

protected int mCompletedIndex

Constructor Detail

ConcatNode

@SafeVarargs
public ConcatNode(OutputNode<IN>... sources)

Method Detail

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.

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.

emitBufferedValuesFor

public void emitBufferedValuesFor(int index)