Skip to main content
Module

x/rxjs/mod.ts>scheduled

Deno port of RXJS
ziv/deno-rxjs
Latest
function scheduled
import { scheduled } from "https://deno.land/x/rxjs@v1.0.2/mod.ts";

Converts from a common ObservableInput type to an observable where subscription and emissions are scheduled on the provided scheduler.

Parameters

input: ObservableInput<T>

The observable, array, promise, iterable, etc you would like to schedule

scheduler: SchedulerLike

The scheduler to use to schedule the subscription and emissions from the returned observable.