Class ArrayStreamDataSource<T>

constructor

• new ArrayStreamDataSource<T>(...value: T[]): ArrayStreamDataSource<T>

  Type Parameters

  • T

  Parameters

  • ...value: T[]

  Returns ArrayStreamDataSource<T>

dataPos

value

current

• current(): T

  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 T

hasNext

• hasNext(): boolean

  Returns boolean

  true if additional data is present false if not

lookAhead

• lookAhead(cnt?: number): ITERATION_STATUS | T

  looks ahead cnt without changing the internal data "pointers" of the data source (this is mostly needed by possibly infinite constructs like lazy streams, because they do not know by definition their boundaries)

  Parameters

  • cnt: number = 1

    the elements to look ahead

  Returns ITERATION_STATUS | T

  either the element or ITERATION_STATUS.EO_STRM if we hit the end of the stream before finding the "cnt" element

next

• next(): ITERATION_STATUS | T

  returns the next element in the stream

  Returns ITERATION_STATUS | T

reset

• reset(): void

  resets the position to the beginning

  Returns void

StaticofArray

• ofArray<T>(data: T[]): ArrayStreamDataSource<T>

  chunk-safe factory, takes the backing array directly instead of spreading it into the constructor call (spreading large arrays overflows the argument stack)

  Type Parameters

  • T

  Parameters

  • data: T[]

    the array to stream over

  Returns ArrayStreamDataSource<T>