stream property

Stream<T> get stream

Implementation

Stream<T> get stream => Stream.multi((controller) {
      // replay last value
      if (_hasValue) controller.add(_value);
      final sub = _innterCtrl.stream.listen(
        controller.add,
        onError: controller.addError,
        onDone: controller.close,
      );
      controller.onCancel = sub.cancel;
    }, isBroadcast: true);