exhaust

import { exhaust } from "https://raw.githubusercontent.com/surma/observables-with-streams/28c55be6d855780c677fd1f4ba975f4d3144891d/src/index.ts";

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

function exhaust<T>(): Transform<Observable<T>, T>;

exhaust<T>(): Transform<Observable<T>, T>

[src]

§Type Parameters

[src]

§Return Type

Transform<Observable<T>, T>

[src]

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