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

A collection of observables built with ReadableStreams & friends.

Latest

function sample

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

sample<T>(notifier: Observable<unknown>): Transform<T, T>

Emits the most recently emitted value from the Observable whenever the notifier emits. If no new value has been emitted from the source observable since the last time the notifier emitted, nothing will be emitted.

Type Parameters

Parameters

notifier: Observable<unknown>

Observable that triggers the sampling of the source observable.

Returns

Transform<T, T>

Transform that emits whenever the notifier emits, provided the source observable has emitted a new value in the mean time.