Options
All
  • Public
  • Public/Protected
  • All
Menu

Multicasts pushed values to a variable number of async iterable iterators as receivers or subscribers.

Does not buffer pushed values; if no receivers are registered, pushed values are silently discarded.

Type parameters

  • A

Hierarchy

  • Multicast

Implements

  • AsyncIterable<A>

Index

Constructors

constructor

Properties

Private Readonly init

init: () => PushAdapter<A>

Type declaration

Readonly receivers

receivers: Set<PushAdapter<A>> = new Set()

Methods

[Symbol.asyncIterator]

  • [Symbol.asyncIterator](): AsyncIterableIterator<A>

Optional onStart

  • onStart(): void

Optional onStop

  • onStop(): void

push

  • push(value: A): this

Legend

  • Constructor
  • Property
  • Method
  • Property
  • Method
  • Private property
  • Static property

Generated using TypeDoc