import { Channel } from "https://deno.land/x/async_channels@v1.0.0-alpha45/channel.ts";
Properties
protected
current: Stateprotected
optional
currentVal: Tprotected
stateEventTarget: EventTargetprotected
transitionEventTarget: EventTargetMethods
protected
debug(...args: unknown[])protected
error(...args: unknown[])protected
updateState(t: Transition, val?: T): voidprotected
waitForState(...states: State[]): Promise<T | undefined>close()
flatMap<TOut>(): Receiver<TOut>
fn: (val: T) => Iterable<TOut> | AsyncIterable<TOut>,
bufferSize?,
options?: ChannelPipeOptions | undefined,
receive(abortCtrl?: AbortController): Promise<[T, true] | [undefined, false]>
send(val: T, abortCtrl?: AbortController): Promise<void>
[Symbol.asyncIterator](): AsyncGenerator<T, void, void>