mainly refactoring & addons

2024-10-29 10:03:24 +01:00
parent 91a4319b28
commit 0710116feb
127 changed files with 4234 additions and 1815 deletions
@@ -0,0 +1,33 @@
+import 'package:rxdart/rxdart.dart';
+
+final _lastEventTimes = <Subject, Map<dynamic, int>>{};
+
+extension SubjectAddRecent<T> on Subject<T> {
+  void addWhenMoreRecent(
+    int timestamp,
+    dynamic identifier,
+    T value,
+  ) {
+    _lastEventTimes[this] ??= {};
+
+    if ((_lastEventTimes[this]?[identifier] ?? 0) < timestamp) {
+      _lastEventTimes[this]![identifier] = timestamp;
+      add(value);
+    }
+  }
+
+  void updateWhenMoreRecent(
+    int timestamp,
+    dynamic identifier,
+    T Function(T? currentValue) update,
+  ) {
+    assert(this is BehaviorSubject, 'This only works with BehaviourSubject');
+
+    _lastEventTimes[this] ??= {};
+
+    if ((_lastEventTimes[this]?[identifier] ?? 0) < timestamp) {
+      _lastEventTimes[this]![identifier] = timestamp;
+      add(update((this as BehaviorSubject<T>).valueOrNull));
+    }
+  }
+}