Skip to content
This repository was archived by the owner on Feb 17, 2025. It is now read-only.

Commit a2147c3

Browse files
committed
Add Message interfaces for messages
1 parent 23cf2a0 commit a2147c3

File tree

4 files changed

+18
-3
lines changed

4 files changed

+18
-3
lines changed

src/Message.php

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
<?php
2+
3+
declare(strict_types=1);
4+
5+
namespace ReactParallel\ObjectProxy;
6+
7+
interface Message
8+
{
9+
public function hash(): string;
10+
11+
public function objectHash(): string;
12+
}

src/Message/Call.php

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,9 @@
55
namespace ReactParallel\ObjectProxy\Message;
66

77
use parallel\Channel;
8+
use ReactParallel\ObjectProxy\Message;
89

9-
final class Call
10+
final class Call implements Message
1011
{
1112
private Channel $channel;
1213

src/Message/Destruct.php

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,9 @@
44

55
namespace ReactParallel\ObjectProxy\Message;
66

7-
final class Destruct
7+
use ReactParallel\ObjectProxy\Message;
8+
9+
final class Destruct implements Message
810
{
911
private string $hash;
1012
private string $objectHash;

src/Proxy.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ public function __destruct()
102102

103103
private function setUpHandlers(): void
104104
{
105-
$this->factory->streams()->channel($this->in)->subscribe(function (object $message): void {
105+
$this->factory->streams()->channel($this->in)->subscribe(function (Message $message): void {
106106
if ($message instanceof Call) {
107107
$this->handleCall($message);
108108
}

0 commit comments

Comments
 (0)