com.robopupu.api.graph.nodes

Class ZipInputNode<IN,OUT>

java.lang.Object

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

com.robopupu.api.graph.nodes.ZipInputNode<IN,OUT>

All Implemented Interfaces:

InputNode<IN>, OutputNode<OUT>

public class ZipInputNode<IN,OUT>
extends Node<IN,OUT>

ZipInputNode is used as a specific input node for a ZipNode.

Field Summary

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

graph, inputNodes

Constructor Summary

Constructors

Constructor and Description
ZipInputNode(ZipNode<OUT> zipNode, int index)

Method Summary

Modifier and Type	Method and Description
int	getIndex()
ZipNode<OUT>	getZipNode()
protected OUT	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, onCompleted, 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

Constructor Detail

ZipInputNode

public ZipInputNode(ZipNode<OUT> zipNode,
                    int index)

Method Detail

getIndex

public int getIndex()

getZipNode

public ZipNode<OUT> getZipNode()

processInput

protected OUT 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,OUT>

Parameters:

source - An OutputNode that emitted the input.

input - The input Object.