subscribe | /lib/mod.ts | effection@4.0.0-alpha.1 | Deno

Skip to main content

Deno 2 is finally here 🎉️

x/effection/lib/mod.ts>subscribe

Structured concurrency and effects for JavaScript

thefrontside/effection

Latest

Menu

mod.ts (default module)

createScopeInternal

abort-signal.ts

CoroutineOptions

createCoroutine

lazy-promise.ts

lazyPromiseWithResolvers

createScopeInternal

TaskGroupContext

with-resolvers.ts

function subscribe

import { subscribe } from "https://deno.land/x/effection@4.0.0-alpha.1/lib/mod.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

T

R

Parameters

iter: AsyncIterator<T, R>

the iterator to convert

Returns

Subscription<T, R>

a subscription that will produce each item of iter