Cleanup

Author: roxblnfk

src/Internal/Transport/DetachedClient.php

@@ -22,7 +22,7 @@
  * @internal Client is an internal library class, please do not use it in your code.
  * @psalm-internal Temporal\Internal\Transport
  */
-final class DetachedClient implements ClientInterface, Destroyable
+final class DetachedClient implements ClientInterface
 {
     /** @var list<int> */
     private array $requests = [];

tests/Functional/WorkflowTestCase.php

@@ -436,6 +436,6 @@ public function setUp(): void
      */
     private static function getPrivate(object $object, string $key): mixed
     {
-        return (static fn(object $value) => $value->{$key} ?? null)->call($object, $object);
+        return (static fn(object $value) => $value->{$key} ?? null)->bindTo(null, $object)($object);
     }
 }

tests/Unit/Framework/ClientMock.php

@@ -9,6 +9,7 @@
 use Temporal\Exception\Failure\CanceledFailure;
 use Temporal\Internal\Queue\QueueInterface;
 use Temporal\Internal\Transport\ClientInterface;
+use Temporal\Internal\Transport\DetachedClient;
 use Temporal\Internal\Transport\Request\UndefinedResponse;
 use Temporal\Worker\Transport\Command\CommandInterface;
 use Temporal\Worker\Transport\Command\FailureResponseInterface;
@@ -25,7 +26,6 @@ final class ClientMock implements ClientInterface
     private const ERROR_REQUEST_ID_DUPLICATION =
         'Unable to create a new request because a ' .
         'request with id %d has already been sent';
-
     private const ERROR_REQUEST_NOT_FOUND =
         'Unable to receive a request with id %d because ' .
         'a request with that identifier was not sent';
@@ -104,9 +104,13 @@ public function reject(CommandInterface $command, \Throwable $reason): void
         $request->reject($reason);
     }
 
-    public function fork(): self
+    public function fork(): ClientInterface
     {
-        return $this;
+        return new DetachedClient($this, function (array $ids): void {
+            foreach ($ids as $id) {
+                unset($this->requests[$id]);
+            }
+        });
     }
 
     public function destroy(): void {}