From 7653717432a489e8573bda8770625e4c4cdcb86c Mon Sep 17 00:00:00 2001 From: sergey boyko Date: Tue, 10 Jun 2025 16:09:54 -0400 Subject: [PATCH 1/2] Fixed failure on unix socket usage during transfer --- src/ServerSocketPipeProvider.php | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/ServerSocketPipeProvider.php b/src/ServerSocketPipeProvider.php index ed3c3e4..32a7a99 100644 --- a/src/ServerSocketPipeProvider.php +++ b/src/ServerSocketPipeProvider.php @@ -62,7 +62,10 @@ public function provideFor(ReadableStream&ResourceStream $stream, ?Cancellation ); } - $uri = (string) $address; + $uri = match ($address->getType()) { + SocketAddressType::Internet => 'tcp://' . $address->toString(), + SocketAddressType::Unix => 'unix://' . $address->toString(), + }; $server = $this->servers[$uri] ??= self::bind($uri, $this->bindContext); $pipe->send($server, $address); From 965925739d8072690486cace315b7741d89afbd3 Mon Sep 17 00:00:00 2001 From: Aaron Piotrowski Date: Sun, 17 May 2026 10:03:06 -0500 Subject: [PATCH 2/2] Add missing import --- src/ServerSocketPipeProvider.php | 1 + 1 file changed, 1 insertion(+) diff --git a/src/ServerSocketPipeProvider.php b/src/ServerSocketPipeProvider.php index 32a7a99..ad0a7d7 100644 --- a/src/ServerSocketPipeProvider.php +++ b/src/ServerSocketPipeProvider.php @@ -14,6 +14,7 @@ use Amp\Serialization\Serializer; use Amp\Socket\BindContext; use Amp\Socket\SocketAddress; +use Amp\Socket\SocketAddressType; use Amp\Socket\SocketException; use Amp\Sync\Channel; use Amp\Sync\ChannelException;