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

A collection of observables built with ReadableStreams & friends.

Latest

function forEach

Re-export

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

forEach<T>(f: (x: T) => Promise<unknown> | unknown): Transform<T>

Calls a function for each item emitted by an observable without waiting for the function to return to forward the item. Exceptions thrown by the function will be caught and ignored.

Type Parameters

Parameters

f: (x: T) => Promise<unknown> | unknown

Function called with each emitted value.

Returns

Transform<T>

Transform that emits the same items as the original observable.