Merge dcfbfc4 into 7bd2311

reliforp · Nov 25, 2023 · 5ebaf00 · 5ebaf00
2 parents 7bd2311 + dcfbfc4
commit 5ebaf00
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 2 deletions.
diff --git a/src/Command/Inspector/DaemonCommand.php b/src/Command/Inspector/DaemonCommand.php
@@ -13,6 +13,7 @@
 
 namespace Reli\Command\Inspector;
 
+use Amp\CancelledException;
 use Amp\DeferredCancellation;
 use Reli\Inspector\Daemon\Dispatcher\DispatchTable;
 use Reli\Inspector\Daemon\Reader\Protocol\Message\TraceMessage;
@@ -138,7 +139,12 @@ function () use ($reader, $dispatch_table, $trace_output) {
                 }
             );
         }
-        await($futures, $cancellation->getCancellation());
+
+        try {
+            await($futures, $cancellation->getCancellation());
+        } catch (CancelledException $e) {
+            Log::debug('cancelled', ['exception' => $e->getMessage()]);
+        }
 
         return 0;
     }

diff --git a/src/Command/Inspector/TopLikeCommand.php b/src/Command/Inspector/TopLikeCommand.php
@@ -13,6 +13,7 @@
 
 namespace Reli\Command\Inspector;
 
+use Amp\CancelledException;
 use Amp\DeferredCancellation;
 use Reli\Inspector\Daemon\Dispatcher\DispatchTable;
 use Reli\Inspector\Daemon\Dispatcher\WorkerPool;
@@ -139,7 +140,12 @@ function () use ($reader, $dispatch_table, $formatter) {
                 }
             );
         }
-        await($futures, $cancellation->getCancellation());
+
+        try {
+            await($futures, $cancellation->getCancellation());
+        } catch (CancelledException $e) {
+            Log::debug('cancelled', ['exception' => $e->getMessage()]);
+        }
 
         return 0;
     }