fix: Add errors from .subscribe() to .stream() streamController (#…

…506) * fix: add subscription error on stream * add parameter name to subscription callback * revert realtime changes
supabase · Jun 9, 2023 · a4cb4c5 · a4cb4c5
1 parent 044f32c
commit a4cb4c5
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/packages/supabase/lib/src/supabase_stream_builder.dart b/packages/supabase/lib/src/supabase_stream_builder.dart
@@ -343,7 +343,11 @@ class SupabaseStreamBuilder extends Stream<SupabaseStreamEvent> {
         _streamData.removeAt(deletedIndex);
         _addStream();
       }
-    }).subscribe();
+    }).subscribe((status, [error]) {
+      if (error != null) {
+        _streamController?.addError(error);
+      }
+    });
 
     PostgrestFilterBuilder query = _queryBuilder.select();
     if (_streamFilter != null) {