Class PsyStream

java.lang.Object

coneforest.psylla.core.PsyStream

All Implemented Interfaces:

PsyCloseable, PsyConcatenable<PsyFormalStream<PsyObject>>, PsyFormalStream<PsyObject>, PsyObject, PsySequential<PsyObject>, PsyStreamable<PsyObject>

@Type("stream")
public class PsyStream
extends Object
implements PsyFormalStream<PsyObject>

The representation of stream.

Field Summary

Fields

Modifier and Type	Field	Description
static final ContextAction	PSY_ITERATE	Context action of the iterate operator.
static final ContextAction	PSY_STREAMTOMARK	Context action of the streamtomark operator.

Fields inherited from interface PsyCloseable

PSY_CLOSE

Fields inherited from interface PsyConcatenable

PSY_CONCAT

Fields inherited from interface PsyFormalStream

PSY_COUNT, PSY_DISTINCT, PSY_FILTERED, PSY_LIMITED, PSY_MAPPED, PSY_PEEKED, PSY_REDUCE, PSY_SKIPPED, PSY_SORTED

Fields inherited from interface PsyObject

PSY_CLONE, PSY_EQ, PSY_HASHCODE, PSY_INSTANCEOF, PSY_NE, PSY_TOSTRING, PSY_TOSTRINGBUFFER, PSY_TYPE

Fields inherited from interface PsySequential

PSY_FORALL

Fields inherited from interface PsyStreamable

PSY_STREAM

Method Summary

Modifier and Type	Method	Description
static PsyStream	psyIterate(PsyObject o, PsyExecutable oUnaryOp, PsyContext oContext)
Stream<PsyObject>	stream()

Methods inherited from class Object

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

Methods inherited from interface PsyFormalStream

psyClose, psyConcat, psyCount, psyDistinct, psyFiltered, psyForAll, psyLimited, psyMapped, psyPeeked, psyReduce, psySkipped, psySorted, psyStream

Methods inherited from interface PsyObject

convert, execute, invoke, psyClone, psyEq, psyHashCode, psyInstanceOf, psyNe, psySyntax, psyToString, psyToStringBuffer, psyType, toSyntaxString, typeName

Field Details

PSY_ITERATE

@OperatorType("iterate")
public static final ContextAction PSY_ITERATE

Context action of the iterate operator.

PSY_STREAMTOMARK

@OperatorType("streamtomark")
public static final ContextAction PSY_STREAMTOMARK

Context action of the streamtomark operator.

Method Details

psyIterate

public static PsyStream psyIterate(PsyObject o,
 PsyExecutable oUnaryOp,
 PsyContext oContext)

stream

public Stream<PsyObject> stream()

Specified by:

stream in interface PsyFormalStream<PsyObject>