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

x/stream_observables/mod.ts>exhaust

A collection of observables built with ReadableStreams & friends.
Latest
function exhaust
import { exhaust } from "https://deno.land/x/stream_observables@v1.3/mod.ts";

Converts a higher-order Observable into a first-order Observable by dropping inner Observables while the previous inner Observable has not yet completed.

Returns

Transform that emits items from the first observable until it is exhausted, then continues with the next observable emitted.