Skip to main content
Using Deno in production at your company? Earn free Deno merch.
Give us feedback
Module

x/earthstar/src/streams/stream_utils.ts>BlockingBus

Earthstar is a tool for private, undiscoverable, offline-first networks.
earthstar-project/earthstar
Go to Latest
class BlockingBus
import { BlockingBus } from "https://deno.land/x/earthstar@v10.0.0/src/streams/stream_utils.ts";

Properties

private
callbacks: Set<(item: T) => void | Promise<void>>
private
lock: LockStream

Methods

on(cb: (item: T) => void | Promise<void>)
send(item: T)