Skip to main content
The Deno 2 Release Candidate is here
Learn more
Module

x/async_channels/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/mod.ts";
const { subscribe } = pipe;

Parameters

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