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

A collection of observables built with ReadableStreams & friends.

Latest

function filter

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

filter<T>(f: (x: T) => boolean): Transform<T>

Returns a Transform that emits all items for which f returns true.

Type Parameters

f: (x: T) => boolean

Function called with each emitted item. If it returns true, the item is emitted. Otherwise the item is discarded.

Transform that emits some items from the original observable.