Package coneforest.psylla.core

Interface PsyFormalStream<T extends PsyObject>

All Superinterfaces:

PsyCloseable, PsyConvertableToName, PsyConvertableToString, PsyObject, PsySequential<T>, PsyStreamable<T>

All Known Implementing Classes:

PsyRange, PsyStream

public interface PsyFormalStream<T extends PsyObject>
extends PsyStreamable<T>, PsyCloseable

Field Summary

Fields

Modifier and Type	Field	Description
static PsyOperator[]	OPERATORS

Method Summary

Modifier and Type	Method	Description
default void	psyClose()	Closes this formalstream.
default PsyFormalStream<T>	psyConcat(PsyFormalStream<T> oStream)
default PsyInteger	psyCount()	Returns the count of elements in this formalstream.
default PsyFormalStream<T>	psyFiltered(PsyExecutable oPredicate, PsyContext oContext)	Returns a stream over elements of this stream that satisfies the given predicate.
default void	psyForAll(PsyObject oProc, PsyContext oContext)
default PsyFormalStream<T>	psyLimited(PsyInteger oCount)	Returns a formalstream consisting of the elements of this formalstream, truncated to be no longer than oCount in length.
default PsyFormalStream<PsyObject>	psyMapped(PsyExecutable oMapper, PsyContext oContext)
default T	psyReduce(T oIdentity, PsyExecutable oAccumulator, PsyContext oContext)
default PsyFormalStream<T>	psySkipped(PsyInteger oCount)	Returns a formalstream consisting of the remaining elements of this formalstream after discarding the first oCount elements of the stream.
default PsyFormalStream<T>	psySorted(PsyExecutable oComparator, PsyContext oContext)
default PsyFormalStream<T>	psyStream()
Stream<T>	stream()

Methods inherited from interface coneforest.psylla.core.PsyObject

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

Field Detail

OPERATORS

static final PsyOperator[] OPERATORS

Method Detail

psyStream

default PsyFormalStream<T> psyStream()

Specified by:

psyStream in interface PsyStreamable<T extends PsyObject>

psyCount

default PsyInteger psyCount()

Returns the count of elements in this formalstream.

Returns:

a count

psyClose

default void psyClose()

Closes this formalstream.

Specified by:

psyClose in interface PsyCloseable

psyConcat

default PsyFormalStream<T> psyConcat(PsyFormalStream<T> oStream)

psyMapped

default PsyFormalStream<PsyObject> psyMapped(PsyExecutable oMapper,
                                             PsyContext oContext)
                                      throws PsyException

Throws:

PsyException

psySorted

default PsyFormalStream<T> psySorted(PsyExecutable oComparator,
                                     PsyContext oContext)

psySkipped

default PsyFormalStream<T> psySkipped(PsyInteger oCount)
                               throws PsyRangeCheckException

Returns a formalstream consisting of the remaining elements of this formalstream after discarding the first oCount elements of the stream.

Parameters:

oCount - the number of leading elements to skip

Returns:

a skipped stream

Throws:

PsyRangeCheckException - when oCount is negative

psyLimited

default PsyFormalStream<T> psyLimited(PsyInteger oCount)
                               throws PsyRangeCheckException

Returns a formalstream consisting of the elements of this formalstream, truncated to be no longer than oCount in length.

Parameters:

oCount - the number of elements the stream should be limited to

Returns:

a limited stream

Throws:

PsyRangeCheckException - when oCount is negative

psyFiltered

default PsyFormalStream<T> psyFiltered(PsyExecutable oPredicate,
                                       PsyContext oContext)
                                throws PsyException

Returns a stream over elements of this stream that satisfies the given predicate.

Parameters:

oPredicate - a predicate

oContext - a context in which a predicate is called

Returns:

a filtered stream

Throws:

PsyException

psyForAll

default void psyForAll(PsyObject oProc,
                       PsyContext oContext)
                throws PsyException

Specified by:

psyForAll in interface PsySequential<T extends PsyObject>

Specified by:

psyForAll in interface PsyStreamable<T extends PsyObject>

Throws:

PsyException

psyReduce

default T psyReduce(T oIdentity,
                    PsyExecutable oAccumulator,
                    PsyContext oContext)
             throws PsyException

Throws:

PsyException

stream

Stream<T> stream()