Merge pull request #66 from reactphp-parallel/add-thread-method-to-registry

Add thread method to registry

Author: WyriHaximus

src/Proxy.php

@@ -19,8 +19,6 @@
 use WyriHaximus\Metrics\Registry\Counters;
 
 use function array_key_exists;
-use function bin2hex;
-use function random_bytes;
 use function serialize;
 use function unserialize;
 
@@ -29,7 +27,6 @@
 
 final class Proxy extends ProxyList
 {
-    private const RANDOM_BYTES_LENGTH       = 13;
     private const HASNT_PROXYABLE_INTERFACE = false;
 
     private Factory $factory;
@@ -124,7 +121,7 @@ public function thread(object $object, string $interface): object
         $in               = new Channel(Channel::Infinite);
         $destruct         = new Channel(Channel::Infinite);
         $this->destruct[] = $destruct;
-        $instance         = new Instance($object, $interface, TRUE_, $in, bin2hex(random_bytes(self::RANDOM_BYTES_LENGTH)));
+        $instance         = $this->registry->thread($object, $interface, $in);
 
         $this->factory->call(
             static function (string $object, string $interface, string $hash, Channel $in, Channel $destruct): void {

src/Proxy/Registry.php

@@ -8,12 +8,16 @@
 use ReactParallel\ObjectProxy\Generated\ProxyList;
 
 use function array_key_exists;
+use function bin2hex;
+use function random_bytes;
 
 use const WyriHaximus\Constants\Boolean\FALSE_;
 use const WyriHaximus\Constants\Boolean\TRUE_;
 
 final class Registry extends ProxyList
 {
+    private const RANDOM_BYTES_LENGTH = 13;
+
     private Channel $in;
 
     /** @var array<string, Instance> */
@@ -76,4 +80,13 @@ public function share(object $object, string $interface): Instance
 
         return $instance;
     }
+
+    public function thread(object $object, string $interface, Channel $in): Instance
+    {
+        $instance                           = new Instance($object, $interface, TRUE_, $in, bin2hex(random_bytes(self::RANDOM_BYTES_LENGTH)));
+        $this->instances[$instance->hash()] = $instance;
+        $this->shared[$interface]           = $instance->hash();
+
+        return $instance;
+    }
 }