import { type Stream } from "https://deno.land/x/effection@3.0.0-beta.3/mod.ts";
The Effection equivalent of an AsyncIterable
.
Like async iterables, streams do not actually have state themselves, but contain the recipe for how to create a Subscription
Methods
subscribe(): Operation<Subscription<T, TReturn>>