fromAsyncFunction | /sources/from-async-function.ts | stream_observables@v1.3

A collection of observables built with ReadableStreams & friends.

Latest

function fromAsyncFunction

import { fromAsyncFunction } from "https://deno.land/x/stream_observables@v1.3/sources/from-async-function.ts";

fromAsyncFunction<T>(f: () => Promise<T>): Observable<T>

Creates an observable from an asynchronous function. The observable emits exactly one value when once the function returns.

Type Parameters

f: () => Promise<T>

Async function that will be awaited.

New observable that emits the value the async function returns.