declare the incoming method frames directly on the enum

src/Transport/Frame/Method.php

@@ -3,8 +3,24 @@
 
 namespace Innmind\AMQP\Transport\Frame;
 
+use Innmind\AMQP\Transport\Frame\Value\{
+    Unpacked,
+    Bits,
+    LongString,
+    ShortString,
+    UnsignedLongInteger,
+    UnsignedLongLongInteger,
+    UnsignedOctet,
+    UnsignedShortInteger,
+    Table,
+};
+use Innmind\TimeContinuum\Clock;
 use Innmind\IO\Readable\Frame;
-use Innmind\Immutable\Maybe;
+use Innmind\Immutable\{
+    Maybe,
+    Sequence,
+    Predicate\Instance,
+};
 
 /**
  * @psalm-immutable
@@ -282,4 +298,125 @@ public function equals(self $method): bool
     {
         return $method === $this;
     }
+
+    /**
+     * @return Frame<Sequence<Value>>
+     */
+    public function incomingFrame(Clock $clock): Frame
+    {
+        /**
+         * @psalm-suppress NamedArgumentNotAllowed
+         * @var Frame<Sequence<Unpacked>>
+         */
+        $frame = match ($this) {
+            Method::basicQosOk,
+            Method::basicRecoverOk,
+            Method::channelCloseOk,
+            Method::connectionCloseOk,
+            Method::exchangeDeclareOk,
+            Method::exchangeDeleteOk,
+            Method::queueBindOk,
+            Method::queueUnbindOk,
+            Method::transactionSelectOk,
+            Method::transactionCommitOk,
+            Method::transactionRollbackOk => Frame\NoOp::of(Sequence::of()), // no arguments
+            Method::basicConsumeOk => ShortString::frame()->map(Sequence::of(...)), // consumer tag
+            Method::basicCancelOk => ShortString::frame()->map(Sequence::of(...)), // consumer tag
+            Method::basicReturn => Frame\Composite::of(
+                static fn(Unpacked ...$values) => Sequence::of(...$values),
+                UnsignedShortInteger::frame(), // reply code
+                ShortString::frame(), // reply text
+                ShortString::frame(), // exchange
+                ShortString::frame(), // routing key
+            ),
+            Method::basicDeliver => Frame\Composite::of(
+                static fn(Unpacked ...$values) => Sequence::of(...$values),
+                ShortString::frame(), // consumer tag
+                UnsignedLongLongInteger::frame(), // delivery tag
+                Bits::frame(), // redelivered
+                ShortString::frame(), // exchange
+                ShortString::frame(), // routing key
+            ),
+            Method::basicGetOk => Frame\Composite::of(
+                static fn(Unpacked ...$values) => Sequence::of(...$values),
+                UnsignedLongLongInteger::frame(), // delivery tag
+                Bits::frame(), // redelivered
+                ShortString::frame(), // exchange
+                ShortString::frame(), // routing key
+                UnsignedLongInteger::frame(), // message count
+            ),
+            Method::basicGetEmpty => ShortString::frame()->map(Sequence::of(...)), // reserved,
+            Method::channelOpenOk => LongString::frame()->map(Sequence::of(...)), // reserved
+            Method::channelFlow => Bits::frame()->map(Sequence::of(...)), // active
+            Method::channelFlowOk => Bits::frame()->map(Sequence::of(...)), // active
+            Method::channelClose => Frame\Composite::of(
+                static fn(Unpacked ...$values) => Sequence::of(...$values),
+                UnsignedShortInteger::frame(), // reply code
+                ShortString::frame(), // reply text
+                UnsignedShortInteger::frame(), // failing class id
+                UnsignedShortInteger::frame(), // failing method id
+            ),
+            Method::connectionStart => Frame\Composite::of(
+                static fn(Unpacked ...$values) => Sequence::of(...$values),
+                UnsignedOctet::frame(), // major version
+                UnsignedOctet::frame(), // minor version
+                Table::frame($clock), // server properties
+                LongString::frame(), // mechanisms
+                LongString::frame(), // locales
+            ),
+            Method::connectionSecure => LongString::frame()->map(Sequence::of(...)), // challenge
+            Method::connectionTune => Frame\Composite::of(
+                static fn(Unpacked ...$values) => Sequence::of(...$values),
+                UnsignedShortInteger::frame(), // max channels
+                UnsignedLongInteger::frame(), // max frame size
+                UnsignedShortInteger::frame(), // heartbeat delay
+            ),
+            Method::connectionOpenOk => ShortString::frame()->map(Sequence::of(...)), // known hosts
+            Method::connectionClose => Frame\Composite::of(
+                static fn(Unpacked ...$values) => Sequence::of(...$values),
+                UnsignedShortInteger::frame(), // reply code
+                ShortString::frame(), // reply text
+                UnsignedShortInteger::frame(), // failing class id
+                UnsignedShortInteger::frame(), // failing method id
+            ),
+            Method::queueDeclareOk => Frame\Composite::of(
+                static fn(Unpacked ...$values) => Sequence::of(...$values),
+                ShortString::frame(), // queue
+                UnsignedLongInteger::frame(), // message count
+                UnsignedLongInteger::frame(), // consumer count
+            ),
+            Method::queuePurgeOk => UnsignedLongInteger::frame()->map(Sequence::of(...)), // message count
+            Method::queueDeleteOk => UnsignedLongInteger::frame()->map(Sequence::of(...)), // message count
+            Method::basicAck,
+            Method::basicCancel,
+            Method::basicConsume,
+            Method::basicGet,
+            Method::basicPublish,
+            Method::basicQos,
+            Method::basicRecover,
+            Method::basicRecoverAsync,
+            Method::basicReject,
+            Method::channelOpen,
+            Method::connectionOpen,
+            Method::connectionSecureOk,
+            Method::connectionStartOk,
+            Method::connectionTuneOk,
+            Method::exchangeDeclare,
+            Method::exchangeDelete,
+            Method::queueBind,
+            Method::queueDeclare,
+            Method::queueDelete,
+            Method::queuePurge,
+            Method::queueUnbind,
+            Method::transactionCommit,
+            Method::transactionRollback,
+            Method::transactionSelect => throw new \LogicException('Server should never send this method'),
+        };
+
+        return $frame->map(
+            static fn($values) => $values
+                ->keep(Instance::of(Unpacked::class))
+                ->map(static fn($unpacked) => $unpacked->unwrap()),
+        );
+    }
 }

src/Transport/Frame/Value/Bits.php

@@ -37,6 +37,8 @@ public static function of(bool $first, bool ...$bits): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Frame/Value/Decimal.php

@@ -34,6 +34,8 @@ public static function of(int $value, int $scale): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Frame/Value/LongString.php

@@ -42,6 +42,8 @@ public static function of(Str $string): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Frame/Value/Sequence.php

@@ -41,6 +41,8 @@ public static function of(Value ...$values): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(Clock $clock): Frame

src/Transport/Frame/Value/ShortString.php

@@ -42,6 +42,8 @@ public static function of(Str $string): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Frame/Value/SignedLongInteger.php

@@ -42,6 +42,8 @@ public static function of(int $value): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Frame/Value/SignedLongLongInteger.php

@@ -29,6 +29,8 @@ public static function of(int $value): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Frame/Value/SignedOctet.php

@@ -44,6 +44,8 @@ public static function of(int $value): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Frame/Value/SignedShortInteger.php

@@ -42,6 +42,8 @@ public static function of(int $value): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Frame/Value/Symbol.php

@@ -30,6 +30,8 @@ enum Symbol
     case table;
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked>
      */
     public static function frame(Clock $clock, string $symbol): Frame

src/Transport/Frame/Value/Table.php

@@ -41,6 +41,8 @@ public static function of(Map $map): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(Clock $clock): Frame
@@ -94,6 +96,8 @@ public function pack(): Str
     }
 
     /**
+     * @psalm-pure
+     *
      * @param Unpacked<self> $unpacked
      *
      * @return Frame<Unpacked<self>>

src/Transport/Frame/Value/Timestamp.php

@@ -36,6 +36,8 @@ public static function of(PointInTime $point): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(Clock $clock): Frame

src/Transport/Frame/Value/UnsignedLongInteger.php

@@ -53,6 +53,8 @@ public static function of(int $value): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Frame/Value/UnsignedLongLongInteger.php

@@ -54,6 +54,8 @@ public static function of(int $value): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Frame/Value/UnsignedOctet.php

@@ -55,6 +55,8 @@ public static function of(int $octet): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Frame/Value/UnsignedShortInteger.php

@@ -53,6 +53,8 @@ public static function of(int $value): self
     }
 
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Frame/Value/VoidValue.php

@@ -14,6 +14,8 @@
 final class VoidValue implements Value
 {
     /**
+     * @psalm-pure
+     *
      * @return Frame<Unpacked<self>>
      */
     public static function frame(): Frame

src/Transport/Protocol.php

@@ -34,7 +34,6 @@ final class Protocol
 {
     private Clock $clock;
     private Version $version;
-    private Reader $read;
     private Connection $connection;
     private Channel $channel;
     private Exchange $exchange;
@@ -46,7 +45,6 @@ public function __construct(Clock $clock, ArgumentTranslator $translator)
     {
         $this->clock = $clock;
         $this->version = Version::v091;
-        $this->read = new Reader($clock);
         $this->connection = new Connection;
         $this->channel = new Channel;
         $this->exchange = new Exchange($translator);
@@ -65,7 +63,7 @@ public function version(): Version
      */
     public function frame(Method $method): Frame
     {
-        return ($this->read)($method);
+        return $method->incomingFrame($this->clock);
     }
 
     /**