Skip to main content
Module

x/aip/mod.ts>Stage

Async Iterator Pipeline
Latest
interface Stage
import { type Stage } from "https://deno.land/x/aip@v1.2.2/mod.ts";

Async generator function that is supposed to:

  • · add/alter/drop messages flowing through it
  • · perform side-effects based on messages flowing through it.

Call Signatures

(input: AsyncIterable<TMsg>): AsyncIterable<TMsg>