Add pingInterval

Author: CodeDoctorDE

packages/networker/networker_socket/lib/client.dart

@@ -6,6 +6,10 @@ import 'dart:typed_data';
 import 'package:networker/networker.dart';
 import 'package:web_socket_channel/web_socket_channel.dart';
 
+import 'src/web_socket.dart';
+
+export 'src/web_socket.dart';
+
 class NetworkerSocketClient extends NetworkerClient {
   static List<String> supportedSchemes = List.unmodifiable(['ws', 'wss']);
 
@@ -14,6 +18,7 @@ class NetworkerSocketClient extends NetworkerClient {
   @override
   final Uri address;
   final Iterable<String>? protocols;
+  final Duration? pingInterval;
 
   WebSocketChannel? get channel => _channel;
 
@@ -26,15 +31,15 @@ class NetworkerSocketClient extends NetworkerClient {
   @override
   Stream<void> get onOpen => _onOpen.stream;
 
-  NetworkerSocketClient(this.address, {this.protocols});
+  NetworkerSocketClient(this.address, {this.protocols, this.pingInterval});
 
   @override
   Future<void> init() async {
     if (isOpen) {
       return;
     }
-    final channel =
-        _channel = WebSocketChannel.connect(address, protocols: protocols);
+    final channel = _channel = constructWebSocketChannel(address,
+        protocols: protocols, pingInterval: pingInterval);
     channel.stream.listen((event) {
       onMessage(event);
     }, onDone: () {

packages/networker/networker_socket/lib/src/web_socket.dart

@@ -0,0 +1,11 @@
+import 'package:web_socket_channel/web_socket_channel.dart';
+
+import 'web_socket_stub.dart' as ws
+    if (dart.library.html) 'web_socket_html.dart'
+    if (dart.library.io) 'web_socket_io.dart';
+
+WebSocketChannel constructWebSocketChannel(Uri uri,
+    {Iterable<String>? protocols, Duration? pingInterval}) {
+  return ws.constructWebSocketChannel(uri,
+      protocols: protocols, pingInterval: pingInterval);
+}

packages/networker/networker_socket/lib/src/web_socket_html.dart

@@ -0,0 +1,7 @@
+import 'package:web_socket_channel/html.dart';
+import 'package:web_socket_channel/web_socket_channel.dart';
+
+WebSocketChannel constructWebSocketChannel(Uri url,
+    {Iterable<String>? protocols, Duration? pingInterval}) {
+  return HtmlWebSocketChannel.connect(url, protocols: protocols);
+}

packages/networker/networker_socket/lib/src/web_socket_io.dart

@@ -0,0 +1,8 @@
+import 'package:web_socket_channel/io.dart';
+import 'package:web_socket_channel/web_socket_channel.dart';
+
+WebSocketChannel constructWebSocketChannel(Uri url,
+    {Iterable<String>? protocols, Duration? pingInterval}) {
+  return IOWebSocketChannel.connect(url,
+      protocols: protocols, pingInterval: pingInterval);
+}

packages/networker/networker_socket/lib/src/web_socket_stub.dart

@@ -0,0 +1,7 @@
+import 'package:web_socket_channel/web_socket_channel.dart';
+
+WebSocketChannel constructWebSocketChannel(Uri uri,
+    {Iterable<String>? protocols, Duration? pingInterval}) {
+  throw UnsupportedError(
+      'WebSocketChannel is not supported in this environment. Please use a different implementation.');
+}