BlockingBus | /src/streams/stream_utils.ts | earthstar@v10.0.0-alpha.4

Earthstar is a tool for private, undiscoverable, offline-first networks.

class BlockingBus

import { BlockingBus } from "https://deno.land/x/earthstar@v10.0.0-alpha.4/src/streams/stream_utils.ts";

Type Parameters

private

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

private

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

send(item: T)