Class FlatMapStreamDataSource<T, S>

Same for flatmap to deal with element -> stream mappings

Type Parameters

  • T

  • S

Hierarchy

  • FlatMapStreamDataSource

Implements

Constructors

Properties

_currPos: number = 0
activeDataSource: IStreamDataSource<S>

the currently active stream coming from an incoming element once the end of this one is reached it is swapped out by another one from the next element

inputDataSource: IStreamDataSource<T>
mapFunc: StreamMapper<T>
walkedDataSources: any[] = []

Methods

  • returns the current element, returns the same element as the previous next call if there is no next before current called then we will call next as initial element

    Returns ITERATION_STATUS | S

  • returns the next element in the stream difference to next is, that the internal data position is not changed, so next still will deliver the next item from the current data position. Look ahead is mostly needed internally by possible endless data constructs which have no fixed data boundary, or index positions. (aka infinite sets, or flatmapped constructs)

    Parameters

    • cnt: number = 1

    Returns ITERATION_STATUS | S

Generated using TypeDoc