/sinks/mod.ts | stream_observables@v1.3

import * as streamObservables from "https://deno.land/x/stream_observables@v1.3/sinks/mod.ts";

Functions

f collect	Collects all values from the observable into an array.
f discard	Sink for observables that discards all values. Useful to leave at the end of a chain.
f extractFirst	Resolves with the first element emitted by the observable, then releases the observable. If no items are emitted the promise is rejected.
f extractLast	Resolves with the last element emitted by the observable. If no items are emitted the promise is rejected.
f reduce	Accumulates value, starting with `v0` and applying `f` to each emitted item. If no items are emitted the promise is rejected.
f single	Resolves with the only element emitted by the observable. If zero or more than one items are emitted, the promise is rejected.
f subscribe	Alias for discard.