diff --git a/src/Command/Inspector/TopLikeCommand.php b/src/Command/Inspector/TopLikeCommand.php index 31a7fe0f..ccaf73d0 100644 --- a/src/Command/Inspector/TopLikeCommand.php +++ b/src/Command/Inspector/TopLikeCommand.php @@ -116,7 +116,7 @@ function (string $watcher_id, $stream) { 'update' => $update_target_message->target_process_list->getArray(), 'current' => $dispatch_table->worker_pool->debugDump(), ]); - $dispatch_table->updateTargets($update_target_message->target_process_list); + yield from $dispatch_table->updateTargets($update_target_message->target_process_list); Log::debug('target updated', [$dispatch_table->worker_pool->debugDump()]); } });