Refactor receive method to wait for incoming messages

xconnio · May 14, 2024 · 805641d · 805641d
1 parent 2857299
commit 805641d
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/lib/src/types.dart b/lib/src/types.dart
@@ -243,12 +243,13 @@ class ClientSideLocalBaseSession implements IBaseSession {
 
   @override
   Future<Object> receive() async {
-    if (_incomingMessages.isEmpty) {
-      await _completer.future;
-      _completer = Completer();
+    if (_incomingMessages.isNotEmpty) {
+      return _incomingMessages.removeFirst();
     }
 
-    return _incomingMessages.removeFirst();
+    await _completer.future;
+    _completer = Completer();
+    return receive();
   }
 
   @override