Package com.singularsys.extensions.stream

Class StreamSendToStream

java.lang.Object

com.singularsys.jep.functions.PostfixMathCommand

com.singularsys.extensions.stream.StreamSendToStream

All Implemented Interfaces:

CallbackEvaluationI, JepComponent, PostfixMathCommandI, Serializable

public class StreamSendToStream
extends PostfixMathCommand
implements CallbackEvaluationI, JepComponent

An assignment operator allowing unclosed steams to be saved to a variable. For example

[1..50] . map(x=>x^2) --> s
s . filter(x=> x%2==0)

The variable can only be used once.

This function is not included in StreamOperatorTable it can be added with

ot.insertOperator(
    new Operator("-->",
        new StreamSendToStream(),
        Operator.BINARY+Operator.LEFT),
    ot.getAssign());

Since:

Jep 4.1 extensions 2.2

See Also:

• Serialized Form

Field Summary

Fields inherited from class com.singularsys.jep.functions.PostfixMathCommand

curNumberOfParameters, description, name, NaN, numberOfParameters

Constructor Summary

Constructors

Constructor	Description
StreamSendToStream()

Method Summary

Modifier and Type	Method	Description
Object	evaluate(Node node, Evaluator pv)	Evaluate the operator.
JepComponent	getLightWeightInstance()	Gets a light-weight instance suitable for using in multiple threads.
void	init(Jep jep)	Initialize the component.

Methods inherited from class com.singularsys.jep.functions.PostfixMathCommand

asArray, asBool, asDouble, asInt, asLong, asStrictInt, asString, asType, checkNumberOfParameters, getDescription, getDescription, getDescriptionWithType, getName, getNumberOfParameters, run, setCurNumberOfParameters, setDescription, setName, toString, toString

Methods inherited from class java.lang.Object

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

Constructor Details

StreamSendToStream

public StreamSendToStream()

Method Details

evaluate

public Object evaluate(Node node,
 Evaluator pv)
                throws EvaluationException

Evaluate the operator. The left hand child node is evaluated, the Variable or LValueI on the right hand is then set to this value. As a stream can only be used once the function returns zero.

Specified by:

evaluate in interface CallbackEvaluationI

Parameters:

node - tree to evaluate

pv - the evaluator

Returns:

Zero.

Throws:

EvaluationException - if the calculation cannot be performed

See Also:

• Evaluator

init

public void init(Jep jep)

Description copied from interface: JepComponent

Initialize the component. This method is called whenever a component is added to Jep. Hence, it allows components to keep track of the other components they may rely on.

Specified by:

init in interface JepComponent

Parameters:

jep - the current Jep instance

getLightWeightInstance

public JepComponent getLightWeightInstance()

Description copied from interface: JepComponent

Gets a light-weight instance suitable for using in multiple threads.

Specified by:

getLightWeightInstance in interface JepComponent

Returns:

either a new instance, null or 'this'.