From a4cb4c530330bf03aa37ae2521e6b6d2f3b96fbf Mon Sep 17 00:00:00 2001
From: Tyler <18113850+dshukertjr@users.noreply.github.com>
Date: Fri, 9 Jun 2023 23:21:53 +0900
Subject: [PATCH] fix: Add errors from `.subscribe()` to `.stream()`
 streamController (#506)

* fix: add subscription error on stream

* add parameter name to subscription callback

* revert realtime changes
---
 packages/supabase/lib/src/supabase_stream_builder.dart | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/packages/supabase/lib/src/supabase_stream_builder.dart b/packages/supabase/lib/src/supabase_stream_builder.dart
index 1cee7286..39651196 100644
--- 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) {