PublishSubject<T> constructor

PublishSubject<T>(
  1. {void onListen(
      ),
    1. void onCancel(
        ),
      1. bool sync: false}
      )

      Constructs a PublishSubject, optionally pass handlers for onListen, onCancel and a flag to handle events sync.

      See also StreamController.broadcast

      Implementation

      factory PublishSubject(
          {void Function() onListen, void Function() onCancel, bool sync = false}) {
        // ignore: close_sinks
        final controller = StreamController<T>.broadcast(
          onListen: onListen,
          onCancel: onCancel,
          sync: sync,
        );
      
        return PublishSubject<T>._(
          controller,
          controller.stream,
        );
      }