com.robopupu.api.graph.nodes

Class BufferNode<IN>

java.lang.Object

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

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

All Implemented Interfaces:

InputNode<IN>, OutputNode<IN>

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

BufferNode buffers a max amount of input values before emitting them as output values.

Field Summary

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

graph, inputNodes

Constructor Summary

Constructors

Constructor and Description
BufferNode(int capacity)

Method Summary

Modifier and Type	Method and Description
void	doOnReset() Invoked by InputNode.onCompleted(OutputNode).
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, doOnError, doOnInput, 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

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferNode

public BufferNode(int capacity)

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.

doOnReset

public 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>