supabase: Allow setting timeout of RealtimeClient.

Author: john

packages/realtime_client/lib/realtime_client.dart

@@ -1,4 +1,4 @@
-export 'src/constants.dart' show RealtimeLogLevel;
+export 'src/constants.dart' show RealtimeConstants, RealtimeLogLevel;
 export 'src/realtime_channel.dart';
 export 'src/realtime_client.dart';
 export 'src/realtime_presence.dart';

packages/realtime_client/lib/src/constants.dart

@@ -9,6 +9,8 @@ class Constants {
   };
 }
 
+typedef RealtimeConstants = Constants;
+
 enum SocketStates {
   /// Client attempting to establish a connection
   connecting,

packages/supabase/lib/src/realtime_client_options.dart

@@ -14,9 +14,13 @@ class RealtimeClientOptions {
   /// Level of realtime server logs to to be logged
   final RealtimeLogLevel? logLevel;
 
+  /// the timeout to trigger push timeouts
+  final Duration? timeout;
+
   /// {@macro realtime_client_options}
   const RealtimeClientOptions({
     this.eventsPerSecond,
     this.logLevel,
+    this.timeout,
   });
 }

packages/supabase/lib/src/supabase_client.dart

@@ -4,6 +4,7 @@ import 'package:http/http.dart';
 import 'package:supabase/src/constants.dart';
 import 'package:supabase/supabase.dart';
 import 'package:yet_another_json_isolate/yet_another_json_isolate.dart';
+import 'package:realtime_client/realtime_client.dart';
 
 import 'auth_http_client.dart';
 import 'counter.dart';
@@ -263,6 +264,7 @@ class SupabaseClient {
       headers: {'apikey': _supabaseKey, ...headers},
       logLevel: options.logLevel,
       httpClient: _authHttpClient,
+      timeout: options.timeout ?? RealtimeConstants.defaultTimeout,
     );
   }