com.robopupu.api.graph.nodes

Class ObserverNode<IN>

java.lang.Object

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

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

All Implemented Interfaces:

InputNode<IN>, OutputNode<IN>

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

ObserverNode takes an NodeObserver for which it delegates invocations to methods Node.onInput(OutputNode, Object), Node.onCompleted(OutputNode), Node.onError(OutputNode, Throwable), and Node.onReset().

Field Summary

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

graph, inputNodes

Constructor Summary

Constructors

Constructor and Description
ObserverNode(NodeObserver<IN> observer)

Method Summary

Modifier and Type	Method and Description
protected void	doOnError(OutputNode<?> source, java.lang.Throwable throwable) Invoked by InputNode.onCompleted(OutputNode).
protected void	doOnReset() Invoked by InputNode.onCompleted(OutputNode).
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, 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, whenTextChanged

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ObserverNode

public ObserverNode(NodeObserver<IN> observer)

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.

doOnError

protected void doOnError(OutputNode<?> source,
                         java.lang.Throwable throwable)

Description copied from class: Node

Invoked by InputNode.onCompleted(OutputNode). This method can be overridden in subclasses for hooking on the error received events.

Overrides:

doOnError in class Node<IN,IN>

Parameters:

source - The OutputNode notifying about error.

throwable - A Throwable representing the error.

doOnReset

protected void doOnReset()

Description copied from class: Node

Invoked by InputNode.onCompleted(OutputNode). This method can be overridden in subclasses for hooking on the reset events.

Overrides:

doOnReset in class Node<IN,IN>