public class SumNode<IN> extends Node<IN,java.lang.Double>
SumNode sums the received input values until InputNode.onCompleted(OutputNode)
is invoked.graph, inputNodes| Constructor and Description |
|---|
SumNode() |
| Modifier and Type | Method and Description |
|---|---|
void |
doOnReset()
Invoked by
InputNode.onCompleted(OutputNode). |
void |
onCompleted(OutputNode<?> outputNode)
Invoked when the specified source
OutputNode is completed. |
protected java.lang.Double |
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. |
action, action, addInputNode, attach, begin, begin, beginTimer, beginTimer, buffer, completed, concat, concatStrings, count, createErrorMessage, detach, dispatchError, dispatchReset, distinct, doOnCompleted, doOnError, doOnInput, 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, whenTextChangedprotected java.lang.Double processInput(OutputNode<IN> source, IN input)
NodeInputNode.onInput(OutputNode, Object) when the given input Object
has been received from the OutputNode that emitted it.processInput in class Node<IN,java.lang.Double>source - An OutputNode that emitted the input.input - The input Object.public void onCompleted(OutputNode<?> outputNode)
InputNodeOutputNode is completed.onCompleted in interface InputNode<IN>onCompleted in class Node<IN,java.lang.Double>outputNode - The completed OutputNode.public void doOnReset()
NodeInputNode.onCompleted(OutputNode). This method can be overridden
in subclasses for hooking on the reset events.