toStream property

Stream<T> toStream

Implementation

Stream<T> get toStream {
  StreamController<T>? controller;
  void __listener() {
    if (controller?.hasListener == true) {
      controller?.add(value);
    }
  }

  controller = StreamController<T>(
    onListen: () => addListener(__listener),
    onCancel: () {
      removeListener(__listener);
      if (controller?.hasListener != true) controller?.close();
    },
  );

  return controller.stream;
}