Switching off network provider on iOS does not immediately stop WebSo…

…cket connection
blackhorse-one · Feb 5, 2025 · 9afe566 · 9afe566
1 parent abc7151
commit 9afe566
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/lib/src/connect_io.dart b/lib/src/connect_io.dart
@@ -11,7 +11,7 @@ Future<WebSocketChannel> connect(StompConfig config) async {
     var webSocketFuture = WebSocket.connect(
       config.connectUrl,
       headers: config.webSocketConnectHeaders,
-    ).then((webSocket) => webSocket..pingInterval = config.heartbeatOutgoing);
+    );
 
     if (config.connectionTimeout.inMilliseconds > 0) {
       webSocketFuture = webSocketFuture.timeout(config.connectionTimeout);

diff --git a/lib/src/stomp_config.dart b/lib/src/stomp_config.dart
@@ -74,8 +74,7 @@ class StompConfig {
   final StompDebugCallback onDebugMessage;
 
   /// The transport url of the WebSocket to connect to
-  String get connectUrl =>
-      _connectUrl ??= useSockJS ? SockJsUtils().generateTransportUrl(url) : url;
+  String get connectUrl => _connectUrl ??= useSockJS ? SockJsUtils().generateTransportUrl(url) : url;
 
   String? _connectUrl;
 
@@ -128,6 +127,7 @@ class StompConfig {
     Duration? heartbeatIncoming,
     Duration? heartbeatOutgoing,
     Duration? connectionTimeout,
+    Duration? pingInterval,
     bool? useSockJS,
     Map<String, String>? stompConnectHeaders,
     Map<String, dynamic>? webSocketConnectHeaders,
@@ -148,9 +148,9 @@ class StompConfig {
       heartbeatIncoming: heartbeatIncoming ?? this.heartbeatIncoming,
       heartbeatOutgoing: heartbeatOutgoing ?? this.heartbeatOutgoing,
       connectionTimeout: connectionTimeout ?? this.connectionTimeout,
+      pingInterval: pingInterval ?? this.pingInterval,
       useSockJS: useSockJS ?? this.useSockJS,
-      webSocketConnectHeaders:
-          webSocketConnectHeaders ?? this.webSocketConnectHeaders,
+      webSocketConnectHeaders: webSocketConnectHeaders ?? this.webSocketConnectHeaders,
       stompConnectHeaders: stompConnectHeaders ?? this.stompConnectHeaders,
       beforeConnect: beforeConnect ?? this.beforeConnect,
       onConnect: onConnect ?? this.onConnect,