Skip to content

Commit f58ed2c

Browse files
authored
fix(realtime): Lower heartbeat interval to 25s (#1119)
1 parent 6976fae commit f58ed2c

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

packages/realtime_client/lib/src/constants.dart

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ import 'package:realtime_client/src/version.dart';
33
class Constants {
44
static const String vsn = '1.0.0';
55
static const Duration defaultTimeout = Duration(milliseconds: 10000);
6+
static const int defaultHeartbeatIntervalMs = 25000;
67
static const int wsCloseNormal = 1000;
78
static const Map<String, String> defaultHeaders = {
89
'X-Client-Info': 'realtime-dart/$version',

packages/realtime_client/lib/src/realtime_client.dart

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ class RealtimeClient {
6565
final WebSocketTransport transport;
6666
final Client? httpClient;
6767
final _log = Logger('supabase.realtime');
68-
int heartbeatIntervalMs = 30000;
68+
int heartbeatIntervalMs = Constants.defaultHeartbeatIntervalMs;
6969
Timer? heartbeatTimer;
7070

7171
/// reference ID of the most recently sent heartbeat.
@@ -122,7 +122,7 @@ class RealtimeClient {
122122
String endPoint, {
123123
WebSocketTransport? transport,
124124
this.timeout = Constants.defaultTimeout,
125-
this.heartbeatIntervalMs = 30000,
125+
this.heartbeatIntervalMs = Constants.defaultHeartbeatIntervalMs,
126126
this.logger,
127127
RealtimeEncode? encode,
128128
RealtimeDecode? decode,

packages/realtime_client/test/socket_test.dart

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ void main() {
7979
});
8080
expect(socket.timeout, const Duration(milliseconds: 10000));
8181
expect(socket.longpollerTimeout, 20000);
82-
expect(socket.heartbeatIntervalMs, 30000);
82+
expect(socket.heartbeatIntervalMs, Constants.defaultHeartbeatIntervalMs);
8383
expect(
8484
socket.logger is void Function(
8585
String? kind,

0 commit comments

Comments
 (0)