Class FilteredStreamDatasource<T>

constructor

• new FilteredStreamDatasource<T>(
      filterFunc: (data: T) => boolean,
      parent: IStreamDataSource<T>,
  ): FilteredStreamDatasource<T>

  Type Parameters

  • T

  Parameters

  • filterFunc: (data: T) => boolean
  • parent: IStreamDataSource<T>

  Returns FilteredStreamDatasource<T>

_current

_filterIdx

_unfilteredPos

filterFunc

inputDataSource

current

• current(): ITERATION_STATUS | 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 ITERATION_STATUS | T

hasNext

• hasNext(): boolean

  in order to filter we have to make a look ahead until the first next allowed element hence we prefetch the element and then serve it via next

  Returns boolean

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 LazyStreams, 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

  serve the next element

  Returns ITERATION_STATUS | T

reset

• reset(): void

  resets the position to the beginning

  Returns void