subscribe | /lib/async.ts | effection@3.0.3

Module

x/effection/lib/async.ts>subscribe

Structured concurrency and effects for JavaScript

thefrontside/effection

Latest

run

mod.ts (default module)

all

run

run

function subscribe

import { subscribe } from "https://deno.land/x/effection@3.0.3/lib/async.ts";

subscribe<T, R>(iter: AsyncIterator<T, R>): Subscription<T, R>

Convert any AsyncIterator into an effection Subscription

This allows you to consume any AsyncIterator as a Subscription.

Type Parameters

Parameters

iter: AsyncIterator<T, R>

the iterator to convert

Returns

Subscription<T, R>

a subscription that will produce each item of iter