com.robopupu.api.graph

Interface InputNode<IN>

All Known Implementing Classes:

Action1Node, ActionNode, BooleanNode, BufferNode, ByteNode, CharacterNode, ConcatNode, ConcatStringsNode, ConditionNode, CountNode, DistinctNode, DoubleNode, FilterNode, FirstNode, FloatNode, FunctionNode, IntegerNode, LastNode, ListNode, LongNode, MergeNode, Node, NthNode, ObserverNode, OutputActionNode, RepeatNode, RequestNode, ReverseNode, ShortNode, SimpleNode, SkipNode, SkipWhileNode, StringNode, SumNode, TakeNode, TextViewNode, ThreadNode, TimerNode, TriggerNode, ViewNode, Zip2Node, Zip3Node, Zip4Node, Zip5Node, Zip6Node, Zip7Node, Zip8Node, Zip9Node, ZipInputNode, ZipNode

public interface InputNode<IN>

Method Summary

Modifier and Type	Method and Description
Graph<?>	getGraph() Gets the Graph that contains this InputNode.
void	onCompleted(OutputNode<?> source) Invoked when the specified source OutputNode is completed.
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 InputNode.
void	setGraph(Graph<?> graph) Sets the Graph that contains this InputNode.

Method Detail

getGraph

Graph<?> getGraph()

Gets the Graph that contains this InputNode.

Returns:

A Graph.

setGraph

void setGraph(Graph<?> graph)

Sets the Graph that contains this InputNode.

Parameters:

graph - A Graph.

onInput

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.

Parameters:

source - The @link OutputNode}.

input - The input Object.

onCompleted

void onCompleted(OutputNode<?> source)

Invoked when the specified source OutputNode is completed.

Parameters:

source - The completed OutputNode.

onError

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

Invoked when the given source OutputNode has detected an error.

Parameters:

source - The OutputNode notifying about error.

throwable - A Throwable representing the detected error.

onReset

void onReset()

Invoked to reset this InputNode.