feat: SingleStreamProvider

Oberhauser-Dev · Jan 16, 2024 · 0e8b298 · 0e8b298
1 parent ff7186b
commit 0e8b298
Show file tree

Hide file tree

Showing 12 changed files with 572 additions and 241 deletions.
diff --git a/wrestling_scoreboard_client/lib/provider/app_state_provider.g.dart b/wrestling_scoreboard_client/lib/provider/app_state_provider.g.dart
diff --git a/wrestling_scoreboard_client/lib/provider/data_provider.dart b/wrestling_scoreboard_client/lib/provider/data_provider.dart
@@ -8,6 +8,22 @@ import 'package:wrestling_scoreboard_common/common.dart';
 
 part 'data_provider.g.dart';
 
+@riverpod
+Stream<T> singleDataStream<T extends DataObject>(
+    SingleDataStreamRef ref, {
+      required int id,
+      T? initialData,
+    }) {
+  // Reload, whenever the stream connects or disconnects
+  // TODO: integrate in updating websocket URL from stream provider
+  ref.watch(webSocketStateStreamProvider);
+
+  // ref.onDispose(webSocketConnectionStream.close);
+  // TODO: e.g. may be triggered twice
+  return dataProvider
+      .streamSingle<T>(id, init: initialData == null);
+}
+
 @riverpod
 Stream<List<T>> manyDataStream<T extends DataObject, S extends DataObject?>(
   ManyDataStreamRef ref, {