From 111f9914e58f22f576b3bb994597b0f5e2c57e91 Mon Sep 17 00:00:00 2001
From: Nikolas Rimikis <rimikis.nikolas@gmail.com>
Date: Mon, 28 Aug 2023 18:38:26 +0200
Subject: [PATCH] test(neon): unit test StreamListenable

Signed-off-by: Nikolas Rimikis <rimikis.nikolas@gmail.com>
---
 .../neon/test/stream_listenable_test.dart     | 73 +++++++++++++++++++
 1 file changed, 73 insertions(+)
 create mode 100644 packages/neon/neon/test/stream_listenable_test.dart

diff --git a/packages/neon/neon/test/stream_listenable_test.dart b/packages/neon/neon/test/stream_listenable_test.dart
new file mode 100644
index 00000000..7ae1d841
--- /dev/null
+++ b/packages/neon/neon/test/stream_listenable_test.dart
@@ -0,0 +1,73 @@
+// ignore_for_file: unreachable_from_main
+
+import 'dart:async';
+
+import 'package:mocktail/mocktail.dart';
+import 'package:neon/src/utils/stream_listenable.dart';
+import 'package:rxdart/rxdart.dart';
+import 'package:test/test.dart';
+
+class MockCallbackFunction extends Mock {
+  FutureOr<void> call();
+}
+
+void main() {
+  group('StreamListenable', () {
+    test('stream', () async {
+      final stream = BehaviorSubject<bool>();
+      final callback = MockCallbackFunction();
+
+      StreamListenable(stream).addListener(callback.call);
+
+      verifyNever(callback.call);
+
+      stream.value = true;
+      await Future.delayed(const Duration(milliseconds: 100));
+      verify(callback.call).called(1);
+
+      stream.value = true;
+      await Future.delayed(const Duration(milliseconds: 100));
+      verify(callback.call).called(1);
+
+      unawaited(stream.close());
+    });
+
+    test('multiStream', () async {
+      final stream = BehaviorSubject<bool>();
+      final stream2 = BehaviorSubject<int>();
+      final callback = MockCallbackFunction();
+
+      StreamListenable.multiListenable({
+        stream,
+        stream2,
+      }).addListener(callback.call);
+
+      verifyNever(callback.call);
+
+      stream.value = true;
+      await Future.delayed(const Duration(milliseconds: 100));
+      verify(callback.call).called(1);
+
+      stream2.value = 3;
+      await Future.delayed(const Duration(milliseconds: 100));
+      verify(callback.call).called(1);
+
+      unawaited(stream.close());
+      unawaited(stream2.close());
+    });
+
+    test('dispose', () {
+      final controller = StreamController();
+
+      final listenable = StreamListenable(controller.stream);
+
+      expect(controller.hasListener, true);
+
+      // ignore: cascade_invocations
+      listenable.dispose();
+
+      expect(controller.isClosed, false);
+      unawaited(controller.close());
+    });
+  });
+}