Node (robopupu-api API)

java.lang.Object
- com.robopupu.api.graph.Node<IN,OUT>

Type Parameters:

IN - The input type.

OUT - The output type.

All Implemented Interfaces:

InputNode<IN>, OutputNode<OUT>

Direct Known Subclasses:

Action1Node, ActionNode, BooleanNode, BufferNode, ByteNode, CharacterNode, ConcatNode, ConcatStringsNode, ConditionNode, CountNode, DistinctNode, DoubleNode, FilterNode, FirstNode, FloatNode, FunctionNode, IntegerNode, LastNode, ListNode, LongNode, MergeNode, NthNode, ObserverNode, OutputActionNode, RepeatNode, RequestNode, ReverseNode, ShortNode, SimpleNode, SkipNode, SkipWhileNode, StringNode, SumNode, TakeNode, TextViewNode, ThreadNode, TimerNode, TriggerNode, ViewNode, ZipInputNode, ZipNode
```
public class Node<IN,OUT>
extends java.lang.Object
implements InputNode<IN>, OutputNode<OUT>
```
Node is a base class for all nodes.

Field Summary

Fields
Modifier and Type Field and Description

protected Graph<?> graph

protected java.util.ArrayList<InputNode<OUT>> inputNodes

Fields
Modifier and Type	Field and Description
`protected Graph<?>`	`graph`
`protected java.util.ArrayList<InputNode<OUT>>`	`inputNodes`

Constructor Summary

Constructors
Modifier Constructor and Description

protected Node()
Constructs a new instance of Node.

Constructors
Modifier	Constructor and Description
`protected`	`Node()` Constructs a new instance of `Node`.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`<T> Node<OUT,T>`	`action(Action action)` Attaches an `ActionNode` with the given `Action` to this `Node`.
`<T> Node<OUT,T>`	`action(Action1<OUT> action)` Attaches an `Action1Node` with the given `Action1` to this `Node`.
`protected InputNode<OUT>`	`addInputNode(InputNode<OUT> inputNode)` Adds the given `InputNode` to the set of attached `InputNode`s.
`InputNode<OUT>`	`attach(InputNode<OUT> inputNode)` Attaches the given `InputNode` to this `OutputNode`.
`static <OUT> OutputActionNode<OUT>`	`begin(OutputAction<OUT> action)` Creates an `OutputActionNode` for the given `OutputAction`.
`static <OUT> RequestNode<OUT,OUT>`	`begin(RequestDelegate<OUT> delegate)` Creates an `RequestNode` for the given `RequestDelegate`.
`static <OUT> TimerNode<OUT>`	`beginTimer(OUT input, long delay)` Creates a `TimerNode` with the given input value and delay.
`static <OUT> TimerNode<OUT>`	`beginTimer(OUT input, long delay, long interval, int repeatCount)` Creates a `TimerNode` with the given input value and parameters.
`Node<OUT,OUT>`	`buffer(int capacity)` Attaches a `BufferNode` with the given capacity to this `Node`.
`protected void`	`completed(OutputNode<?> source)` Invoked to notify all `InputNode`s about completion.
`Node<OUT,OUT>`	`concat(OutputNode<OUT>... sources)` Attaches a `ConcatNode` to the current `OutputNode`.
`Node<OUT,java.lang.String>`	`concatStrings()` Attaches a `ConcatStringsNode` to this `Node`.
`Node<OUT,java.lang.Integer>`	`count()` Attaches a `CountNode` to this `Node`.
`protected java.lang.String`	`createErrorMessage(java.lang.String message, java.lang.String... args)` Creates and formats an error message.
`void`	`detach(InputNode<OUT> inputNode)` Detaches the given `InputNode` from this `OutputNode`.
`protected void`	`dispatchError(OutputNode<?> source, java.lang.Throwable throwable)` Dispatches an error to all `InputNode`s, if any.
`protected void`	`dispatchReset()` Dispatches a resetting to all `InputNode`s, if any.
`Node<OUT,OUT>`	`distinct()` Attaches a `DistinctNode` to this `Node`.
`protected void`	`doOnCompleted(OutputNode<?> source)` Invoked by `InputNode.onCompleted(OutputNode)`.
`protected void`	`doOnError(OutputNode<?> source, java.lang.Throwable throwable)` Invoked by `InputNode.onCompleted(OutputNode)`.
`protected void`	`doOnInput(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.
`protected void`	`doOnReset()` Invoked by `InputNode.onCompleted(OutputNode)`.
`void`	`emitOutput()` Invoked to emit available output value(s) from this `OutputNode`.
`protected void`	`emitOutput(OUT output)` Invoked to emit the given output to attached `InputNode`s, if any.
`Node<OUT,OUT>`	`filter(BooleanFunction<OUT> condition)` Attaches a `FilterNode` with the given `BooleanFunction` to this `Node`.
`Node<OUT,OUT>`	`first()` Attaches a `FirstNode` to this `Node`.
`Node<OUT,OUT>`	`first(BooleanFunction<OUT> condition)` Attaches a `FirstNode` with the given `BooleanFunction` to this `Node`.
`Graph<?>`	`getGraph()` Gets the `Graph` that contains this `InputNode`.
`boolean`	`hasInputNodes()` Tests if this `OutputNode` has any attached @link InputNode}s.
`boolean`	`isErrorReceived()` Tests if an error has been received.
`Node<OUT,OUT>`	`last()` Attaches a `LastNode` to this `Node`.
`Node<OUT,OUT>`	`last(BooleanFunction<OUT> condition)` Attaches a `LastNode` with the given `BooleanFunction` to this `Node`.
`<T> Node<OUT,T>`	`map(Function<OUT,T> function)` Attaches a `FunctionNode` with the given `Function` to this `Node`.
`Node<OUT,OUT>`	`merge(OutputNode<OUT>... sources)` Attaches a `MergeNode` to the current `OutputNode`.
`Node<OUT,OUT>`	`nth(int steps)` Attaches a `NthNode` with the given index parameter to this `Node`.
`Node<OUT,OUT>`	`observer(NodeObserver<OUT> observer)` Attaches an `ObserverNode` with the given `NodeObserver` to this `Node`.
`<T> Node<OUT,T>`	`observer(RequestDelegate<T> delegate)` Attaches an `RequestNode` with the given `RequestDelegate` to this `Node`.
`protected void`	`onAttached(InputNode<OUT> inputNode)` Invoked when the given output `InputNode` has been attached to this `Node`.
`void`	`onCompleted(OutputNode<?> source)` Invoked when the specified source `OutputNode` is completed.
`protected void`	`onDetached(InputNode<OUT> inputNode)` Invoked when the given `InputNode` has been detached from this `Node`.
`void`	`onError(OutputNode<?> source, java.lang.Throwable throwable)` Invoked when the given source `OutputNode` has detected an error.
`void`	`onInput(OutputNode<IN> source, IN input)` Invoked by the given source `OutputNode` for this `InputNode` to receive the input `Object` that was emitted by the `OutputNode`.
`void`	`onReset()` Invoked to reset this `Node`.
`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.
`protected void`	`removeInputNode(InputNode<OUT> inputNode)` Removes the given `InputNode` from the set of attached `InputNode`s.
`Node<OUT,OUT>`	`repeat(int times)` Attaches a `RepeatNode` with the given times parameter to this `Node`.
`Node<OUT,OUT>`	`reverse()` Attaches a `ReverseNode` to this `Node`.
`protected void`	`setErrorReceived(boolean errorReceived)` Sets the flag that indicates if an error is received.
`void`	`setGraph(Graph<?> graph)` Sets the `Graph` that contains this `InputNode`.
`Node<OUT,OUT>`	`skip(int steps)` Attaches a `SkipNode` with the given steps parameter to this `Node`.
`Node<OUT,OUT>`	`skipWhile(BooleanFunction<OUT> condition)` Attaches a `SkipWhileNode` with the given `BooleanFunction` to this `Node`.
`void`	`start()` Invokes the begin node of the `Graph` to emit its value(s).
`Node<OUT,java.lang.String>`	`string()` Attaches a `StringNode` to this `Node`.
`Node<OUT,java.lang.Double>`	`sum()` Attaches a `SumNode` to this `Node`.
`Node<OUT,OUT>`	`take(int steps)` Attaches a `TakeNode` with the given steps parameter to this `Node`.
`Node<OUT,OUT>`	`timer(long delay)` Attaches a `TimerNode` with the given delay to this `Node`.
`Node<OUT,OUT>`	`timer(long delay, long interval, int repeatCount)` Attaches a `TimerNode` with the given parameters to this `Node`.
`Node<OUT,java.lang.Boolean>`	`toBoolean()` Attaches a `BooleanNode` to this `Node`.
`Node<OUT,java.lang.Byte>`	`toByte()` Attaches a `ByteNode` to this `Node`.
`Node<OUT,java.lang.Character>`	`toChar()` Attaches a `CharacterNode` to this `Node`.
`Node<OUT,java.lang.Double>`	`toDouble()` Attaches a `DoubleNode` to this `Node`.
`Node<OUT,java.lang.Float>`	`toFloat()` Attaches a `FloatNode` to this `Node`.
`Node<OUT,java.lang.Integer>`	`toInt()` Attaches an `IntegerNode` to this `Node`.
`Node<OUT,java.lang.Long>`	`toLong()` Attaches a `LongNode` to this `Node`.
`Node<OUT,OUT>`	`toMain()` Transfers the execution to the main thread by attaching a `ThreadNode`.
`Node<OUT,java.lang.Short>`	`toShort()` Attaches a `ShortNode` to this `Node`.
`<T> Node<OUT,OUT>`	`toWorker()` Transfers the execution to a worker thread by attaching a `ThreadNode`.
`static ViewNode`	`whenClicked(android.view.View view)` Creates an `ViewNode` for the given `View`.
`static TextViewNode`	`whenTextChanged(android.widget.TextView textView)` Creates an `TextViewNode` for the given `TextView`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - inputNodes
```
protected final java.util.ArrayList<InputNode<OUT>> inputNodes
```
  - graph
```
protected Graph<?> graph
```
- Constructor Detail
  - Node
```
protected Node()
```
    Constructs a new instance of Node.
- Method Detail
  - begin
```
public static <OUT> OutputActionNode<OUT> begin(OutputAction<OUT> action)
```
    Creates an OutputActionNode for the given OutputAction.
    
    Parameters:
    
    action - A OutputAction.
    
    Returns:
    
    The created OutputActionNode.
  - begin
```
public static <OUT> RequestNode<OUT,OUT> begin(RequestDelegate<OUT> delegate)
```
    Creates an RequestNode for the given RequestDelegate.
    
    Parameters:
    
    delegate - A RequestDelegate.
    
    Returns:
    
    The created RequestNode.
  - beginTimer
```
public static <OUT> TimerNode<OUT> beginTimer(OUT input,
                                              long delay)
```
    Creates a TimerNode with the given input value and delay.
    
    Parameters:
    
    input - The input value.
    
    delay - The delay in milliseconds.
    
    Returns:
    
    The created RequestNode.
  - beginTimer
```
public static <OUT> TimerNode<OUT> beginTimer(OUT input,
                                              long delay,
                                              long interval,
                                              int repeatCount)
```
    Creates a TimerNode with the given input value and parameters.
    
    Parameters:
    
    input - The input value.
    
    delay - The delay in milliseconds.
    
    interval - The interval in milliseconds for repeated timeouts.
    
    repeatCount - The number of repeats.
    
    Returns:
    
    The created RequestNode.
  - whenClicked
```
public static ViewNode whenClicked(android.view.View view)
```
    Creates an ViewNode for the given View.
    
    Parameters:
    
    view - A View.
    
    Returns:
    
    The created ViewNode.
  - whenTextChanged
```
public static TextViewNode whenTextChanged(android.widget.TextView textView)
```
    Creates an TextViewNode for the given TextView.
    
    Parameters:
    
    textView - A TextView.
    
    Returns:
    
    The created TextViewNode.
  - isErrorReceived
```
public boolean isErrorReceived()
```
    Tests if an error has been received.
    
    Returns:
    
    A boolean.
  - setErrorReceived
```
protected void setErrorReceived(boolean errorReceived)
```
    Sets the flag that indicates if an error is received.
    
    Parameters:
    
    errorReceived - A boolean.
  - getGraph
```
public Graph<?> getGraph()
```
    Description copied from interface: InputNode
    
    Gets the Graph that contains this InputNode.
    
    Specified by:
    
    getGraph in interface InputNode<IN>
    
    Specified by:
    
    getGraph in interface OutputNode<OUT>
    
    Returns:
    
    A Graph.
  - setGraph
```
public void setGraph(Graph<?> graph)
```
    Description copied from interface: InputNode
    
    Sets the Graph that contains this InputNode.
    
    Specified by:
    
    setGraph in interface InputNode<IN>
    
    Specified by:
    
    setGraph in interface OutputNode<OUT>
    
    Parameters:
    
    graph - A Graph.
  - emitOutput
```
protected void emitOutput(OUT output)
```
    Invoked to emit the given output to attached InputNodes, if any.
    
    Parameters:
    
    output - The outbut Object.
  - completed
```
protected void completed(OutputNode<?> source)
```
    Invoked to notify all InputNodes about completion.
    
    Parameters:
    
    source - The completed OutputNode.
  - dispatchError
```
protected void dispatchError(OutputNode<?> source,
                             java.lang.Throwable throwable)
```
    Dispatches an error to all InputNodes, if any.
    
    Parameters:
    
    source - The OutputNode that has detected the error.
    
    throwable - A Throwable representing the error.
  - attach
```
public InputNode<OUT> attach(InputNode<OUT> inputNode)
```
    Description copied from interface: OutputNode
    
    Attaches the given InputNode to this OutputNode.
    
    Specified by:
    
    attach in interface OutputNode<OUT>
    
    Parameters:
    
    inputNode - An InputNode.
    
    Returns:
    
    The attached InputNode.
  - addInputNode
```
protected InputNode<OUT> addInputNode(InputNode<OUT> inputNode)
```
    Adds the given InputNode to the set of attached InputNodes.
    
    Parameters:
    
    inputNode - A InputNode.
    
    Returns:
    
    The added InputNode.
  - onAttached
```
protected void onAttached(InputNode<OUT> inputNode)
```
    Invoked when the given output InputNode has been attached to this Node.
    
    Parameters:
    
    inputNode - The attached InputNode.
  - detach
```
public void detach(InputNode<OUT> inputNode)
```
    Description copied from interface: OutputNode
    
    Detaches the given InputNode from this OutputNode.
    
    Specified by:
    
    detach in interface OutputNode<OUT>
    
    Parameters:
    
    inputNode - An InputNode.
  - removeInputNode
```
protected void removeInputNode(InputNode<OUT> inputNode)
```
    Removes the given InputNode from the set of attached InputNodes.
    
    Parameters:
    
    inputNode - A InputNode.
  - onDetached
```
protected void onDetached(InputNode<OUT> inputNode)
```
    Invoked when the given InputNode has been detached from this Node.
    
    Parameters:
    
    inputNode - The detached InputNode.
  - hasInputNodes
```
public boolean hasInputNodes()
```
    Tests if this OutputNode has any attached @link InputNode}s.
    
    Returns:
    
    A boolean value.
  - emitOutput
```
public void emitOutput()
```
    Description copied from interface: OutputNode
    
    Invoked to emit available output value(s) from this OutputNode.
    
    Specified by:
    
    emitOutput in interface OutputNode<OUT>
  - onReset
```
public void onReset()
```
    Invoked to reset this Node.
    
    Specified by:
    
    onReset in interface InputNode<IN>
    
    Specified by:
    
    onReset in interface OutputNode<OUT>
  - dispatchReset
```
protected void dispatchReset()
```
    Dispatches a resetting to all InputNodes, if any.
  - doOnReset
```
protected void doOnReset()
```
    Invoked by InputNode.onCompleted(OutputNode). This method can be overridden in subclasses for hooking on the reset events.
  - onInput
```
public void onInput(OutputNode<IN> source,
                    IN input)
```
    Description copied from interface: InputNode
    
    Invoked by the given source OutputNode for this InputNode to receive the input Object that was emitted by the OutputNode.
    
    Specified by:
    
    onInput in interface InputNode<IN>
    
    Parameters:
    
    source - The @link OutputNode}.
    
    input - The input Object.
  - doOnInput
```
protected void doOnInput(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. This method can be overridden in subclasses for hooking on the input received events.
    
    Parameters:
    
    source - An OutputNode that emitted the input.
    
    input - The input Object.
  - processInput
```
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.
    
    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>
    
    Parameters:
    
    source - The completed OutputNode.
  - doOnCompleted
```
protected void doOnCompleted(OutputNode<?> source)
```
    Invoked by InputNode.onCompleted(OutputNode). This method can be overridden in subclasses for hooking on the completed events.
    
    Parameters:
    
    source - An OutputNode that was completed.
  - onError
```
public void onError(OutputNode<?> source,
                    java.lang.Throwable throwable)
```
    Description copied from interface: InputNode
    
    Invoked when the given source OutputNode has detected an error.
    
    Specified by:
    
    onError in interface InputNode<IN>
    
    Parameters:
    
    source - The OutputNode notifying about error.
    
    throwable - A Throwable representing the detected error.
  - doOnError
```
protected void doOnError(OutputNode<?> source,
                         java.lang.Throwable throwable)
```
    Invoked by InputNode.onCompleted(OutputNode). This method can be overridden in subclasses for hooking on the error received events.
    
    Parameters:
    
    source - The OutputNode notifying about error.
    
    throwable - A Throwable representing the error.
  - start
```
public void start()
```
    Invokes the begin node of the Graph to emit its value(s).
  - createErrorMessage
```
protected java.lang.String createErrorMessage(java.lang.String message,
                                              java.lang.String... args)
```
    Creates and formats an error message.
    
    Parameters:
    
    message - The error message as a String. May contain place holders for formatting.
    
    args - Optional formats args.
    
    Returns:
    
    The created error message as a String.
  - action
```
public <T> Node<OUT,T> action(Action action)
```
    Attaches an ActionNode with the given Action to this Node.
    
    Parameters:
    
    action - An Action.
    
    Returns:
    
    The attached Node.
  - action
```
public <T> Node<OUT,T> action(Action1<OUT> action)
```
    Attaches an Action1Node with the given Action1 to this Node.
    
    Parameters:
    
    action - An Action1.
    
    Returns:
    
    The attached Node.
  - buffer
```
public Node<OUT,OUT> buffer(int capacity)
```
    Attaches a BufferNode with the given capacity to this Node.
    
    Returns:
    
    The attached Node.
  - concat
```
@SafeVarargs
public final Node<OUT,OUT> concat(OutputNode<OUT>... sources)
```
    Attaches a ConcatNode to the current OutputNode.
    
    Returns:
    
    The attached Node.
  - concatStrings
```
public Node<OUT,java.lang.String> concatStrings()
```
    Attaches a ConcatStringsNode to this Node.
    
    Returns:
    
    The attached Node.
  - count
```
public Node<OUT,java.lang.Integer> count()
```
    Attaches a CountNode to this Node.
    
    Returns:
    
    The attached Node.
  - distinct
```
public Node<OUT,OUT> distinct()
```
    Attaches a DistinctNode to this Node.
    
    Returns:
    
    The attached Node.
  - filter
```
public Node<OUT,OUT> filter(BooleanFunction<OUT> condition)
```
    Attaches a FilterNode with the given BooleanFunction to this Node.
    
    Parameters:
    
    condition - A BooleanFunction.
    
    Returns:
    
    The attached Node.
  - first
```
public Node<OUT,OUT> first(BooleanFunction<OUT> condition)
```
    Attaches a FirstNode with the given BooleanFunction to this Node.
    
    Parameters:
    
    condition - A BooleanFunction.
    
    Returns:
    
    The attached Node.
  - first
```
public Node<OUT,OUT> first()
```
    Attaches a FirstNode to this Node.
    
    Returns:
    
    The attached Node.
  - map
```
public <T> Node<OUT,T> map(Function<OUT,T> function)
```
    Attaches a FunctionNode with the given Function to this Node.
    
    Parameters:
    
    function - A Function.
    
    Returns:
    
    The attached Node.
  - last
```
public Node<OUT,OUT> last(BooleanFunction<OUT> condition)
```
    Attaches a LastNode with the given BooleanFunction to this Node.
    
    Parameters:
    
    condition - A BooleanFunction.
    
    Returns:
    
    The attached Node.
  - last
```
public Node<OUT,OUT> last()
```
    Attaches a LastNode to this Node.
    
    Returns:
    
    The attached Node.
  - merge
```
@SafeVarargs
public final Node<OUT,OUT> merge(OutputNode<OUT>... sources)
```
    Attaches a MergeNode to the current OutputNode.
    
    Returns:
    
    The attached Node.
  - nth
```
public Node<OUT,OUT> nth(int steps)
```
    Attaches a NthNode with the given index parameter to this Node.
    
    Parameters:
    
    steps - The index value.
    
    Returns:
    
    The attached Node.
  - observer
```
public Node<OUT,OUT> observer(NodeObserver<OUT> observer)
```
    Attaches an ObserverNode with the given NodeObserver to this Node.
    
    Parameters:
    
    observer - A NodeObserver.
    
    Returns:
    
    The attached Node.
  - repeat
```
public Node<OUT,OUT> repeat(int times)
```
    Attaches a RepeatNode with the given times parameter to this Node.
    
    Parameters:
    
    times - The times parameter.
    
    Returns:
    
    The attached Node.
  - observer
```
public <T> Node<OUT,T> observer(RequestDelegate<T> delegate)
```
    Attaches an RequestNode with the given RequestDelegate to this Node.
    
    Parameters:
    
    delegate - A RequestDelegate.
    
    Returns:
    
    The attached Node.
  - reverse
```
public Node<OUT,OUT> reverse()
```
    Attaches a ReverseNode to this Node.
    
    Returns:
    
    The attached Node.
  - skip
```
public Node<OUT,OUT> skip(int steps)
```
    Attaches a SkipNode with the given steps parameter to this Node.
    
    Parameters:
    
    steps - The steps value.
    
    Returns:
    
    The attached Node.
  - skipWhile
```
public Node<OUT,OUT> skipWhile(BooleanFunction<OUT> condition)
```
    Attaches a SkipWhileNode with the given BooleanFunction to this Node.
    
    Parameters:
    
    condition - A BooleanFunction.
    
    Returns:
    
    The attached Node.
  - string
```
public Node<OUT,java.lang.String> string()
```
    Attaches a StringNode to this Node.
    
    Returns:
    
    The attached Node.
  - sum
```
public Node<OUT,java.lang.Double> sum()
```
    Attaches a SumNode to this Node.
    
    Returns:
    
    The attached Node.
  - take
```
public Node<OUT,OUT> take(int steps)
```
    Attaches a TakeNode with the given steps parameter to this Node.
    
    Parameters:
    
    steps - The steps value.
    
    Returns:
    
    The attached Node.
  - timer
```
public Node<OUT,OUT> timer(long delay)
```
    Attaches a TimerNode with the given delay to this Node.
    
    Parameters:
    
    delay - The delay in milliseconds.
    
    Returns:
    
    The attached Node.
  - timer
```
public Node<OUT,OUT> timer(long delay,
                           long interval,
                           int repeatCount)
```
    Attaches a TimerNode with the given parameters to this Node.
    
    Parameters:
    
    delay - The delay in milliseconds.
    
    interval - The interval in milliseconds for repeated timeouts.
    
    repeatCount - The number of repeats.
    
    Returns:
    
    The attached Node.
  - toBoolean
```
public Node<OUT,java.lang.Boolean> toBoolean()
```
    Attaches a BooleanNode to this Node.
    
    Returns:
    
    The attached Node.
  - toByte
```
public Node<OUT,java.lang.Byte> toByte()
```
    Attaches a ByteNode to this Node.
    
    Returns:
    
    The attached Node.
  - toChar
```
public Node<OUT,java.lang.Character> toChar()
```
    Attaches a CharacterNode to this Node.
    
    Returns:
    
    The attached Node.
  - toDouble
```
public Node<OUT,java.lang.Double> toDouble()
```
    Attaches a DoubleNode to this Node.
    
    Returns:
    
    The attached Node.
  - toFloat
```
public Node<OUT,java.lang.Float> toFloat()
```
    Attaches a FloatNode to this Node.
    
    Returns:
    
    The attached Node.
  - toInt
```
public Node<OUT,java.lang.Integer> toInt()
```
    Attaches an IntegerNode to this Node.
    
    Returns:
    
    The attached Node.
  - toLong
```
public Node<OUT,java.lang.Long> toLong()
```
    Attaches a LongNode to this Node.
    
    Returns:
    
    The attached Node.
  - toShort
```
public Node<OUT,java.lang.Short> toShort()
```
    Attaches a ShortNode to this Node.
    
    Returns:
    
    The attached Node.
  - toMain
```
public Node<OUT,OUT> toMain()
```
    Transfers the execution to the main thread by attaching a ThreadNode.
    
    Returns:
    
    The attached Node.
  - toWorker
```
public <T> Node<OUT,OUT> toWorker()
```
    Transfers the execution to a worker thread by attaching a ThreadNode.
    
    Returns:
    
    The attached Node.

Class Node<IN,OUT>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

inputNodes

graph

Constructor Detail

Node

Method Detail

begin

begin

beginTimer

beginTimer

whenClicked

whenTextChanged

isErrorReceived

setErrorReceived

getGraph

setGraph

emitOutput

completed

dispatchError

attach

addInputNode

onAttached

detach

removeInputNode

onDetached

hasInputNodes

emitOutput

onReset

dispatchReset

doOnReset

onInput

doOnInput

processInput

onCompleted

doOnCompleted

onError

doOnError

start

createErrorMessage

action

action

buffer

concat

concatStrings

count

distinct

filter

first

first

map

last

last

merge

nth

observer

repeat

observer

reverse

skip

skipWhile

string

sum

take

timer

timer

toBoolean

toByte

toChar

toDouble

toFloat

toInt

toLong

toShort

toMain

toWorker