Only send event if stream is not closed (#123)

viamrobotics · Oct 3, 2023 · 2d7dbea · 2d7dbea
1 parent 123abaf
commit 2d7dbea
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/lib/src/media/stream/client.dart b/lib/src/media/stream/client.dart
@@ -176,7 +176,7 @@ class StreamClient {
       _internalListener.pause();
       await _close(name);
       _stream = null;
-      _streamController.add(null);
+      if (!_streamController.isClosed) _streamController.add(null);
     }
   }
 }
diff --git a/lib/src/robot/client.dart b/lib/src/robot/client.dart
@@ -205,7 +205,12 @@ class RobotClient {
     try {
       _checkConnectionTask?.cancel();
       _shouldAttemptReconnection = false;
-      await _streamManager.closeAll();
+      try {
+        await _streamManager.closeAll();
+      } catch (_) {
+        // Do nothing -- we don't care if this fails,
+        // the server should clean up disconnected streams automatically.
+      }
       _sessionsClient.stop();
       await _channel.shutdown();
     } catch (e) {