broadcaster<T> method

StreamController<T> broadcaster<T>({
  1. FutureOr<void> onCancel()?,
})

Creates a StreamController.broadcast that is closed within dispose.

Implementation

StreamController<T> broadcaster<T>({FutureOr<void> Function()? onCancel /*?*/
    }) {
  _sanity();

  final ret = ControlledStreamController<T>.broadcast(onCancel: onCancel);

  ret.done.then((ev) => _ctrls.remove(ret));

  _ctrls.add(ret);

  return ret;
}