public class Action1Node<IN,OUT> extends Node<IN,OUT>
Action1Node
is a Node
that can be used to execute a given Action1
or arbitrary action defined as overridden method Action1.execute(Object)
.graph, inputNodes
Constructor and Description |
---|
Action1Node(Action1<IN> action) |
Modifier and Type | Method and Description |
---|---|
protected void |
execute(IN input) |
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. |
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
protected OUT processInput(OutputNode<IN> source, IN input)
Node
InputNode.onInput(OutputNode, Object)
when the given input Object
has been received from the OutputNode
that emitted it.processInput
in class Node<IN,OUT>
source
- An OutputNode
that emitted the input.input
- The input Object
.protected void execute(IN input)