From 021076cf51c29f1b56cbfdd5955230a0500594da Mon Sep 17 00:00:00 2001 From: as2252258 Date: Thu, 28 Apr 2022 11:56:19 +0800 Subject: [PATCH] modify mysql result --- Abstracts/BaseProcess.php | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/Abstracts/BaseProcess.php b/Abstracts/BaseProcess.php index 894f74b..3c77dc7 100644 --- a/Abstracts/BaseProcess.php +++ b/Abstracts/BaseProcess.php @@ -107,8 +107,8 @@ abstract class BaseProcess implements OnProcessInterface { $this->isStop = true; $value = Context::getContext('waite:process:message'); - if (!empty($value) && Coroutine::exists($value)) { - Coroutine::cancel($value); + if (!is_null($value) && Coroutine::exists((int)$value)) { + Coroutine::cancel((int)$value); } }