Skip to main content
Deno 2 is finally here 🎉️
Learn more
Module

x/async_channels/src/mod.ts>pipe.subscribe

Inspired by Go & Clojure Channels, async_channels provides channels as an asynchronous communication method between asynchronous functions.
Latest
function pipe.subscribe
import { pipe } from "https://deno.land/x/async_channels@v1.0.0-rc8/src/mod.ts";
const { subscribe } = pipe;

Parameters

fn: (_: TMsg) => string | symbol | number
topics: (keyof TObj)[]
optional
pipeOpts: SubscribeOptions