import { StreamBase } from "https://deno.land/x/rimbu@0.13.0/stream/custom/stream-custom.ts";
Methods
assumeNonEmpty(): Stream.NonEmpty<T>
collect<R>(collectFun: CollectFun<T, R>): Stream<R>
concat(...others: ArrayNonEmpty<StreamSource<T>>): Stream.NonEmpty<T>
containsSlice(source: StreamSource.NonEmpty<T>, eq?): boolean
count(): number
countElement(value: T, eq?: Eq<T>): number
countNotElement(value: T, eq?: Eq<T>): number
distinctPrevious(eq?: Eq<T>): Stream<T>
equals(other: StreamSource<T>, eq?: Eq<T>): boolean
filterNotPure<A extends readonly unknown[]>(pred: (value: T, ...args: A) => boolean, ...args: A): Stream<T>
filterPure<A extends readonly unknown[]>(pred: (value: T, ...args: A) => boolean, ...args: A): Stream<T>
flatMap<T2>(flatMapFun: () => StreamSource<T2>): Stream<T2>
flatZip<T2>(flatMapFun: () => StreamSource<T2>): Stream<[T, T2]>
foldStream<R>(init: OptLazy<R>, next: () => R): Stream<R>
forEachPure<A extends readonly unknown[]>(f: (value: T, ...args: A) => void, ...args: A): void
indexWhere(pred: (value: T, index: number) => boolean, occurrance?): number | undefined
indicesWhere(pred: (value: T) => boolean): Stream<number>
intersperse(sep: StreamSource<T>): Stream<T>
join(unnamed 0?): string
mkGroup(unnamed 0?): any
reduceAll(...reducers: any): any
reduceAllStream(...reducers: any): any
reduceStream<O>(reducer: Reducer<T, O>): Stream<O>
splitWhere(pred: (value: T, index: number) => boolean): Stream<T[]>
stream(): this
toString(): string
transform<R>(transformer: Transformer<T, R>): Stream<R>
abstract
[Symbol.iterator](): FastIterator<T>