import { AsyncStreamBase } from "https://deno.land/x/rimbu@0.14.1/stream/async-custom/async-stream-custom.ts";
Methods
append(value: AsyncOptLazy<T>): AsyncStream.NonEmpty<T>
asNormal(): AsyncStream<T>
assumeNonEmpty(): AsyncStream.NonEmpty<T>
asyncStream(): this
collect<R>(collectFun: AsyncCollectFun<T, R>): AsyncStream<R>
concat(...others: ArrayNonEmpty<AsyncStreamSource<T>>): any
containsSlice(source: AsyncStreamSource.NonEmpty<T>, eq?): Promise<boolean>
count(): Promise<number>
countElement(value: T, eq?): Promise<number>
countNotElement(value: T, eq?): Promise<number>
distinctPrevious(eq?: Eq<T>): AsyncStream<T>
drop(amount: number): AsyncStream<T>
dropWhile(pred: (value: T, index: number) => MaybePromise<boolean>): AsyncStream<T>
elementAt<O>(index: number, otherwise?: AsyncOptLazy<O>): Promise<T | O>
equals(other: AsyncStreamSource<T>, eq?: Eq<T>): Promise<boolean>
every(pred: (value: T, index: number) => MaybePromise<boolean>): Promise<boolean>
filter(pred: () => MaybePromise<boolean>): AsyncStream<T>
filterNot(pred: () => MaybePromise<boolean>): AsyncStream<T>
filterNotPure<A extends readonly unknown[]>(pred: (value: T, ...args: A) => MaybePromise<boolean>, ...args: A): AsyncStream<T>
filterPure<A extends readonly unknown[]>(pred: (value: T, ...args: A) => MaybePromise<boolean>, ...args: A): AsyncStream<T>
first<O>(otherwise?: AsyncOptLazy<O>): Promise<T | O>
flatMap<T2>(flatMapFun: () => AsyncStreamSource<T2>): AsyncStream<T2>
flatZip<T2>(flatMapFun: () => AsyncStreamSource<T2>): AsyncStream<[T, T2]>
fold<R>(init: AsyncOptLazy<R>, next: () => MaybePromise<R>): Promise<R>
foldStream<R>(init: AsyncOptLazy<R>, next: () => MaybePromise<R>): AsyncStream<R>
forEach(f: () => MaybePromise<void>, state?): Promise<void>
forEachPure<A extends readonly unknown[]>(f: (value: T, ...args: A) => MaybePromise<void>, ...args: A): Promise<void>
indexed(startIndex?): AsyncStream<[number, T]>
indexWhere(pred: (value: T, index: number) => MaybePromise<boolean>, occurrance?): Promise<number | undefined>
indicesOf(searchValue: T, eq?: Eq<T>): AsyncStream<number>
indicesWhere(pred: (value: T) => MaybePromise<boolean>): AsyncStream<number>
intersperse(sep: AsyncStreamSource<T>): AsyncStream<T>
join(unnamed 0?): Promise<string>
last<O>(otherwise?: AsyncOptLazy<O>): Promise<T | O>
map<T2>(mapFun: (value: T, index: number) => MaybePromise<T2>): AsyncStream<T2>
mapPure<T2, A extends readonly unknown[]>(mapFun: (value: T, ...args: A) => MaybePromise<T2>, ...args: A): AsyncStream<T2>
max<O>(otherwise?: AsyncOptLazy<O>): Promise<T | O>
maxBy<O>(compare: (v1: T, v2: T) => number, otherwise?: AsyncOptLazy<O>): Promise<T | O>
min<O>(otherwise?: AsyncOptLazy<O>): Promise<T | O>
minBy<O>(compare: (v1: T, v2: T) => number, otherwise?: AsyncOptLazy<O>): Promise<T | O>
mkGroup(unnamed 0?): any
prepend(value: AsyncOptLazy<T>): AsyncStream.NonEmpty<T>
reduce<R>(reducer: AsyncReducer<T, R>): Promise<R>
reduceAll<R extends [unknown, unknown, ...unknown[]]>(...reducers: [K in keyof R]: AsyncReducer<T, R[K]>): Promise<any>
reduceAllStream<R extends [unknown, unknown, ...unknown[]]>(...reducers: [K in keyof R]: AsyncReducer<T, R[K]>): any
reduceStream<R>(reducer: AsyncReducer<T, R>): AsyncStream<R>
repeat(amount?: number): AsyncStream<T>
single<O>(otherwise?: AsyncOptLazy<O>): Promise<T | O>
some(pred: (value: T, index: number) => MaybePromise<boolean>): Promise<boolean>
splitWhere(pred: (value: T, index: number) => MaybePromise<boolean>): AsyncStream<T[]>
take(amount: number): AsyncStream<T>
takeWhile(pred: (value: T, index: number) => MaybePromise<boolean>): AsyncStream<T>
toString(): string
transform<R>(transformer: AsyncReducer<T, AsyncStreamSource<R>>): AsyncStream<R>
window<R>(): AsyncStream<R>
abstract
[Symbol.asyncIterator](): AsyncFastIterator<T>