update.

livekit · Dec 18, 2023 · 295a318 · 295a318
1 parent 38c4d2c
commit 295a318
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 10 deletions.
diff --git a/lib/src/core/engine.dart b/lib/src/core/engine.dart
@@ -866,9 +866,7 @@ extension EnginePrivateMethods on Engine {
 
   void _updateConnectionState(ConnectionState newValue,
       {DisconnectReason? reason}) {
-    if (_connectionState == newValue) {
-      return;
-    }
+    if (_connectionState == newValue) return;
 
     logger.fine('Engine ConnectionState '
         '${_connectionState.name} -> ${newValue.name}');

diff --git a/lib/src/core/signal_client.dart b/lib/src/core/signal_client.dart
@@ -185,7 +185,7 @@ class SignalClient extends Disposable with EventsEmittable<SignalEvent> {
       return;
     }
 
-    _ws.sendMessage(req.writeToBuffer());
+    _ws.send(req.writeToBuffer());
   }
 
   Future<void> _onSocketData(dynamic message) async {

diff --git a/lib/src/core/transport.dart b/lib/src/core/transport.dart
@@ -114,7 +114,7 @@ class Transport extends Disposable {
   late final negotiate = Utils.createDebounceFunc(
     (void _) => createAndSendOffer(),
     cancelFunc: (f) => _cancelDebounce = f,
-    wait: connectOptions.timeouts.debounce * 2,
+    wait: connectOptions.timeouts.debounce,
   );
 
   Future<void> setRemoteDescription(rtc.RTCSessionDescription sd) async {

diff --git a/lib/src/support/websocket_utility.dart b/lib/src/support/websocket_utility.dart
@@ -147,11 +147,11 @@ class WebSocketUtility {
     _changeSocketStatus(SocketStatus.kSocketStatusConnected);
   }
 
-  webSocketOnMessage(data) {
+  void webSocketOnMessage(data) {
     onMessage?.call(data);
   }
 
-  webSocketOnDone() {
+  void webSocketOnDone() {
     logger.fine('closed');
     if (_socketStatus == SocketStatus.kSocketStatusConnected) {
       _webSocket?.dispose();
@@ -164,7 +164,7 @@ class WebSocketUtility {
     }
   }
 
-  webSocketOnError(e) {
+  void webSocketOnError(e) {
     WebSocketException ex = e;
     onError?.call(ex);
   }
@@ -192,12 +192,12 @@ class WebSocketUtility {
     _cleanUp();
   }
 
-  void sendMessage(message) {
+  void send(List<int> data) {
     if (_socketStatus != SocketStatus.kSocketStatusConnected) {
       logger.warning('WebSocket not connected');
       return;
     }
-    _webSocket?.send(message);
+    _webSocket?.send(data);
   }
 
   Future<bool> reconnect() async {
-Original file line number
+Diff line change
@@ Expand Up @@
           return;
         }
-        _ws.sendMessage(req.writeToBuffer());
+        _ws.send(req.writeToBuffer());
       }
       Future<void> _onSocketData(dynamic message) async {
@@ Expand Down @@