Merge pull request #20: Add Ping/Pong flags

roadrunner-php · Oct 3, 2023 · d955f58 · d955f58
2 parents 3f6dc5e + f8df7b0
commit d955f58
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 3 deletions.
diff --git a/src/BlockingRelayInterface.php b/src/BlockingRelayInterface.php
@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Spiral\Goridge;
+
+/**
+ * Means that relay can't be used for non-blocking flow.
+ */
+interface BlockingRelayInterface extends RelayInterface
+{
+}
diff --git a/src/Frame.php b/src/Frame.php
@@ -50,7 +50,9 @@ final class Frame
      * @var positive-int Flags for {@see $byte10}
      */
     public const BYTE10_STREAM = 0x01;
-    public const BYTE10_STOP = 0x02; // 2.9.0-alpha just streams
+    public const BYTE10_STOP = 0x02;
+    public const BYTE10_PING = 0x04;
+    public const BYTE10_PONG = 0x08;
 
     /**
      * @psalm-var FrameByte10Value
@@ -124,7 +126,7 @@ public static function packFrame(Frame $frame): string
      * @return HeaderList
      * @internal
      *
-     * @psalm-suppress InvalidReturnStatement, InvalidReturnType
+     * @psalm-suppress LessSpecificReturnStatement, MoreSpecificReturnType
      */
     public static function readHeader(string $header): array
     {

diff --git a/src/StreamRelay.php b/src/StreamRelay.php
@@ -18,7 +18,7 @@
  * prefix:
  * [ flag       ][ message length, unsigned int 64bits, LittleEndian ]
  */
-class StreamRelay extends Relay
+class StreamRelay extends Relay implements BlockingRelayInterface
 {
     /**
      * @var resource