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

A collection of observables built with ReadableStreams & friends.

Latest

function fromNext

import { fromNext } from "https://deno.land/x/stream_observables@v1.3/mod.ts";

fromNext<T>(f: (next: NextFunc<T>) => unknown): Observable<T>

Creates an observable from a function that gets passed the observable's next() function.

Type Parameters

f: (next: NextFunc<T>) => unknown

Function that will be executed with the observable's next() function.

New observable.