as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

变更

Browse Source
This commit is contained in:
向林
2022-10-11 18:28:33 +08:00
parent ceefabb8e4
commit 268f8665d0
2 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kiri-actor/ActorInterface.php
+2 -2
View File
@@ -6,9 +6,9 @@ interface ActorInterface
{ {
/** /**
* @param mixed $message * @param ActorMessage $message
* @return void * @return void
*/ */
public function process(mixed $message): void; public function process(ActorMessage $message): void;
} }
kiri-actor/ActorProcess.php
+5 -4
View File
@@ -47,16 +47,17 @@ class ActorProcess extends BaseProcess
$actorManager = $this->container->get(ActorManager::class); $actorManager = $this->container->get(ActorManager::class);
while (!$this->isStop()) { while (!$this->isStop()) {
$read = json_decode($process->read(), true); $read = json_decode($process->read(), true);
if (is_null($read) || !isset($read['event'])) { if (is_null($read) || !isset($read['category'])) {
continue; continue;
} }
switch ($read['event']) { $message = new ActorMessage($read['userId'], $read['event'], $read['body']);
switch ($read['category']) {
case ActorState::MESSAGE: case ActorState::MESSAGE:
$actorManager->write($read['name'], $read['message']); $actorManager->write($read['name'], $message);
break; break;
case ActorState::CREATE: case ActorState::CREATE:
/** @var ActorInterface $actor */ /** @var ActorInterface $actor */
$actor = $this->container->create($read['class']); $actor = $this->container->create($read['class'], $read['constrict'], $read['config']);
$actorManager->addActor($actor); $actorManager->addActor($actor);
break; break;
case ActorState::SHUTDOWN: case ActorState::SHUTDOWN: