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); } }