Add BlockedRelayInterface and apply it to pipes stream relay; added s…

…tream flags PING and PONG
roadrunner-php · Sep 16, 2023 · 6afb213 · 6afb213
1 parent 3f6dc5e
commit 6afb213
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 2 deletions.
diff --git a/src/BlockedRelayInterface.php b/src/BlockedRelayInterface.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 BlockedRelayInterface 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

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 BlockedRelayInterface
 {
     /**
      * @var resource