import { AsyncStreamBase } from "https://deno.land/x/rimbu@1.1.0/stream/async-custom/index.ts";
Methods
assumeNonEmpty(): AsyncStream.NonEmpty<T>
asyncStream(): this
containsSlice(source: AsyncStreamSource.NonEmpty<T>, options?: { eq?: Eq<T>; negate?: boolean; }): Promise<boolean>
count(): Promise<number>
countElement(value: T, options?: { eq?: Eq<T>; negate?: boolean; }): Promise<number>
distinctPrevious(options?: { eq?: Eq<T>; negate?: boolean; }): AsyncStream<T>
filterPure<A extends readonly unknown[]>(options: { pred: (value: T, ...args: A) => MaybePromise<boolean>; negate?: boolean; }, ...args: A): AsyncStream<T>
foldStream<R>(init: AsyncOptLazy<R>, next: () => MaybePromise<R>): AsyncStream<R>
forEachPure<A extends readonly unknown[]>(f: (value: T, ...args: A) => MaybePromise<void>, ...args: A): Promise<void>
indexWhere(pred: (value: T, index: number) => MaybePromise<boolean>, options?: { occurrance?: number; negate?: boolean; }): Promise<number | undefined>
indicesWhere(pred: (value: T) => MaybePromise<boolean>, options?: { negate?: boolean; }): AsyncStream<number>
intersperse(sep: AsyncStreamSource<T>): AsyncStream<T>
join(unnamed 0?): Promise<string>
mkGroup(unnamed 0?): any
reduceStream<S extends AsyncReducer.CombineShape<T>>(shape: S & AsyncReducer.CombineShape<T>): AsyncStream<AsyncReducer.CombineResult<S>>
splitOnSeq<R>(sepSeq: AsyncStreamSource<T>, options?: { eq?: Eq<T>; collector?: AsyncReducer<T, R> | undefined; }): AsyncStream<R>
splitWhere<R>(pred: (value: T, index: number) => MaybePromise<boolean>, options?: { negate?: boolean; collector?: AsyncReducer<T, R> | undefined; }): AsyncStream<R>
toString(): string
abstract
[Symbol.asyncIterator](): AsyncFastIterator<T>