import { type Subscription } from "https://deno.land/x/effection@3.0.0-beta.3/mod.ts";
The Effection equivalent of an AsyncIterator
A subscription acts like a stateful queue that provides a sequence of values via the next() method. Normally a subscription is created via a Stream.