diff --git a/Database/Pagination.php b/Database/Pagination.php index 4430b43a..7f1b65ee 100644 --- a/Database/Pagination.php +++ b/Database/Pagination.php @@ -35,8 +35,6 @@ class Pagination extends Component /** @var Closure */ private Closure $_callback; - /** @var Coroutine\WaitGroup */ - private Coroutine\WaitGroup $_group; /** * PaginationIteration constructor. diff --git a/HttpServer/Events/OnPipeMessage.php b/HttpServer/Events/OnPipeMessage.php index e956cda8..a11a2615 100644 --- a/HttpServer/Events/OnPipeMessage.php +++ b/HttpServer/Events/OnPipeMessage.php @@ -28,9 +28,6 @@ class OnPipeMessage extends Callback */ public function onHandler(Server $server, int $src_worker_id, $swollen_universalize) { - defer(function () { - fire(Event::SYSTEM_RESOURCE_RELEASES); - }); match ($swollen_universalize['action'] ?? null) { 'kafka' => $this->onKafkaWorker($swollen_universalize), 'crontab' => $this->onCrontabWorker($swollen_universalize), @@ -66,7 +63,6 @@ class OnPipeMessage extends Callback $redis->zAdd(Producer::CRONTAB_KEY, $tickTime, $name); } } - fire(Event::SYSTEM_RESOURCE_RELEASES); }); $handler->increment()->execute(); return 'success';