init Broadcast.new

buffer unread elements per subscriber (at least 1); a new subscriber first receives up to replay of the most recent elements (at most buffer).

Example:

use std.stream { Broadcast }

fn main() io {
  let hub = Broadcast<i32>.new(buffer: 8, replay: 2)
  print("{hub.subscribers()}")
}

0

pub(api) init new(buffer: usize, slow: SlowPolicy = .Block, replay: usize = 0) -> Self

Сложность. O(1).

С версии. 1.0.0-beta

Параметры

Возвращает

Self

Эффекты

не объявлены (чистая, пока тело не говорит иное)

Определено в: std/stream/stream.oxl:581