Update stream.dart

rodydavis · Nov 20, 2024 · b89ce27 · b89ce27
1 parent c1fe818
commit b89ce27
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/packages/signals_core/lib/src/mixins/stream.dart b/packages/signals_core/lib/src/mixins/stream.dart
@@ -5,17 +5,15 @@ import '../../signals_core.dart';
 /// [Stream] implementation for [AsyncState]
 mixin StreamSignalMixin<T> on ReadonlySignal<T> implements Stream<T> {
   final _controller = StreamController<T>.broadcast(sync: true);
-  void Function()? _cleanup;
 
   late final Stream<T> _stream = () {
     final s = toStream();
-    _cleanup = subscribe(_controller.add);
+    onDispose(subscribe(_controller.add));
     return s;
   }();
 
   @override
   void dispose() {
-    _cleanup?.call();
     _controller.close();
     super.dispose();
   }