Skip to main content
Deno 2 is finally here 🎉️
Learn more
Module

x/stream_observables/combiners/mod.ts

A collection of observables built with ReadableStreams & friends.
Latest
import * as streamObservables from "https://deno.land/x/stream_observables@v1.3/combiners/mod.ts";

Functions

Takes in multiple observables but only emits items from the first observable to emit.

Combines items from multiple observables. The resulting observable emits array tuples whenever any of the given observables emit, as long as every observable has emitted at least once. The tuples contain the last emitted item from each observable.

Creates an output Observable which sequentially emits all values from given Observable and then moves on to the next.

When all observables complete, emit the last emitted value from each.

Merges multiple observables by emitting all items from all the observables. Items are emitted in the order they appear.

Alias for amb.

Zips items from multiple observables. The resulting observable emits items as array tuples.