import { StreamBase } from "https://deno.land/x/rimbu@1.1.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>, options?: { eq?: Eq<T>; }): boolean
count(): number
countElement(value: T, options?: { eq?: Eq<T>; negate?: boolean; }): number
distinctPrevious(options?: { eq?: Eq<T>; negate?: boolean; }): Stream<T>
equals(other: StreamSource<T>, unnamed 1?: { eq?: Eq<T>; negate?: boolean; }): boolean
filterPure<A extends readonly unknown[]>(options: { pred: (value: T, ...args: A) => boolean; negate?: 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>
forEach(f: () => void, options?: { state?: TraverseState; }): void
forEachPure<A extends readonly unknown[]>(f: (value: T, ...args: A) => void, ...args: A): void
indexWhere(pred: (value: T, index: number) => boolean, options?: { occurrance?: number; negate?: boolean; }): number | undefined
indicesWhere(pred: (value: T) => boolean, options?: { negate?: boolean; }): Stream<number>
intersperse(sep: StreamSource<T>): Stream<T>
join(unnamed 0?): string
mkGroup(unnamed 0?): any
reduceStream<S extends Reducer.CombineShape<T>>(shape: S & Reducer.CombineShape<T>): Stream<Reducer.CombineResult<S>>
splitOnSeq<R>(sepSeq: StreamSource<T>, options?: { eq?: Eq<T>; collector?: Reducer<T, R> | undefined; }): Stream<R>
splitWhere<R>(pred: (value: T, index: number) => boolean, options?: { negate?: boolean; collector?: Reducer<T, R> | undefined; }): Stream<R>
stream(): this
toString(): string
transform<R>(transformer: Transformer<T, R>): Stream<R>
abstract
[Symbol.iterator](): FastIterator<T>