feat: make toBehaviorSubject sync

tekartik · May 27, 2024 · de21018 · de21018
1 parent f87bb80
commit de21018
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/app_rx/test/helpers_test.dart b/app_rx/test/helpers_test.dart
@@ -13,12 +13,20 @@ void main() {
         expect(subject.value, 1);
       }).unawait();
 
+      StreamSubscription? subscription1;
+      subscription1 = subject.listen((data) {
+        if (data == 1) {
+          subscription1?.cancel();
+          subscription1 = null;
+        }
+      });
       subject.listen((data) {
         if (data == 3) {
           completer.complete();
         }
       });
       await completer.future;
+      expect(subscription1, isNull);
       expect(await subject.first, 3);
       expect(subject.value, 3);
       await subject.close();