File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
packages/supabase/lib/src Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -76,8 +76,8 @@ class SupabaseStreamBuilder extends Stream<SupabaseStreamEvent> {
7676 /// Count of record to be returned
7777 int ? _limit;
7878
79- /// Flag if the stream has at least one time been subscribed to realtime
80- bool _gotSubscribed = false ;
79+ /// Flag that the stream has at least one time been subscribed to realtime
80+ bool _wasSubscribed = false ;
8181
8282 SupabaseStreamBuilder ({
8383 required PostgrestQueryBuilder queryBuilder,
@@ -214,10 +214,10 @@ class SupabaseStreamBuilder extends Stream<SupabaseStreamEvent> {
214214 case RealtimeSubscribeStatus .subscribed:
215215 // Reload all data after a reconnect from postgrest
216216 // First data from postgrest gets loaded before the realtime connect
217- if (_gotSubscribed ) {
217+ if (_wasSubscribed ) {
218218 _getPostgrestData ();
219219 }
220- _gotSubscribed = true ;
220+ _wasSubscribed = true ;
221221 break ;
222222 case RealtimeSubscribeStatus .closed:
223223 _streamController? .close ();
You can’t perform that action at this time.
0 commit comments