Add Message interfaces for messages

Author: WyriHaximus

src/Message/Call.php

@@ -6,7 +6,7 @@
 
 use parallel\Channel;
 
-final class Call
+final class Call implements Message
 {
     private Channel $channel;
 

src/Message/Destruct.php

@@ -4,7 +4,7 @@
 
 namespace ReactParallel\ObjectProxy\Message;
 
-final class Destruct
+final class Destruct implements Message
 {
     private string $hash;
     private string $objectHash;

src/Message/Existence.php

@@ -4,7 +4,7 @@
 
 namespace ReactParallel\ObjectProxy\Message;
 
-final class Existence
+final class Existence implements Message
 {
     private string $hash;
     private string $objectHash;

src/Message/Message.php

@@ -0,0 +1,11 @@
+<?php
+
+declare(strict_types=1);
+
+namespace ReactParallel\ObjectProxy\Message;
+
+interface Message
+{
+    public function hash(): string;
+    public function objectHash(): string;
+}

src/Message/Notify.php

@@ -4,7 +4,7 @@
 
 namespace ReactParallel\ObjectProxy\Message;
 
-final class Notify
+final class Notify implements Message
 {
     private string $hash;
     private string $objectHash;

src/Proxy.php

@@ -10,6 +10,7 @@
 use ReactParallel\ObjectProxy\Message\Call;
 use ReactParallel\ObjectProxy\Message\Destruct;
 use ReactParallel\ObjectProxy\Message\Existence;
+use ReactParallel\ObjectProxy\Message\Message;
 use ReactParallel\ObjectProxy\Message\Notify;
 use ReactParallel\ObjectProxy\Proxy\Instance;
 use WyriHaximus\Metrics\Label;
@@ -113,7 +114,7 @@ public function __destruct()
 
     private function setUpHandlers(): void
     {
-        $this->factory->streams()->channel($this->in)->subscribe(function (object $message): void {
+        $this->factory->streams()->channel($this->in)->subscribe(function (Message $message): void {
             if ($message instanceof Existence) {
                 $this->handleExistence($message);