File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -195,6 +195,10 @@ private function request()
195195 $ this ->lastEventId = $ message ->lastEventId ;
196196 }
197197
198+ if ($ message ->retry !== null ) {
199+ $ this ->reconnectTime = $ message ->retry / 1000 ;
200+ }
201+
198202 if ($ message ->data !== '' ) {
199203 $ this ->emit ($ message ->type , array ($ message ));
200204 if ($ this ->readyState === self ::CLOSED ) {
Original file line number Diff line number Diff line change @@ -29,6 +29,8 @@ public static function parse($data)
2929 $ message ->lastEventId .= $ value ;
3030 } elseif ($ name === 'event ' ) {
3131 $ message ->type = $ value ;
32+ } elseif ($ name === 'retry ' ) {
33+ $ message ->retry = (int )$ value ;
3234 }
3335 }
3436
@@ -53,4 +55,9 @@ public static function parse($data)
5355 * @var string
5456 */
5557 public $ type = 'message ' ;
58+
59+ /**
60+ * @var ?int
61+ */
62+ public $ retry ;
5663}
You can’t perform that action at this time.
0 commit comments