Skip to main content
Module

x/effection/mod.ts>stream

Structured concurrency and effects for JavaScript
Latest
function stream
import { stream } from "https://deno.land/x/effection@3.0.3/mod.ts";

Convert any AsyncIterable into an Effection Stream.

This allows you to consume any AsyncIterable as a Stream.

Parameters

iterable: AsyncIterable<T, R>
  • the async iterable to convert

Returns

a stream that will produce each item of iterable