com.robopupu.api.graph.nodes

Class RequestNode<IN,OUT>

java.lang.Object

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

com.robopupu.api.graph.nodes.RequestNode<IN,OUT>

All Implemented Interfaces:

InputNode<IN>, OutputNode<OUT>, RequestCallback<OUT>

public class RequestNode<IN,OUT>
extends Node<IN,OUT>
implements RequestCallback<OUT>

RequestNode implements a Node that can be used to execute REST requests using RequestDelegate interface.

Field Summary

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

graph, inputNodes

Constructor Summary

Constructors

Constructor and Description
RequestNode(RequestDelegate<OUT> requestDelegate)

Method Summary

Modifier and Type	Method and Description
void	emitOutput() Invoked to emit available output value(s) from this OutputNode.
void	onError(RequestError requestError)
void	onResponse(OUT response)
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.

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, doOnReset, 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

RequestNode

public RequestNode(RequestDelegate<OUT> requestDelegate)

Method Detail

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>

Overrides:

emitOutput in class Node<IN,OUT>

processInput

protected OUT 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,OUT>

Parameters:

source - An OutputNode that emitted the input.

input - The input Object.

onResponse

public void onResponse(OUT response)

Specified by:

onResponse in interface RequestCallback<OUT>

onError

public void onError(RequestError requestError)

Specified by:

onError in interface RequestCallback<OUT>