@@ -74,7 +74,7 @@ |
||
| 74 | 74 | |
| 75 | 75 | if (fwrite( |
| 76 | 76 | $this->out, |
| 77 | - $headerPackage['body'] . $bodyPackage['body'], |
|
| 77 | + $headerPackage['body'].$bodyPackage['body'], |
|
| 78 | 78 | 34 + $headerPackage['size'] + $bodyPackage['size'] |
| 79 | 79 | ) === false) { |
| 80 | 80 | throw new TransportException('unable to write payload to the stream'); |
@@ -99,7 +99,7 @@ |
||
| 99 | 99 | |
| 100 | 100 | socket_send( |
| 101 | 101 | $this->socket, |
| 102 | - $headerPackage['body'] . $bodyPackage['body'], |
|
| 102 | + $headerPackage['body'].$bodyPackage['body'], |
|
| 103 | 103 | 34 + $headerPackage['size'] + $bodyPackage['size'], |
| 104 | 104 | 0 |
| 105 | 105 | ); |
@@ -46,7 +46,7 @@ |
||
| 46 | 46 | */ |
| 47 | 47 | public function call(string $method, $payload, int $flags = 0) |
| 48 | 48 | { |
| 49 | - $header = $method . pack('P', $this->seq); |
|
| 49 | + $header = $method.pack('P', $this->seq); |
|
| 50 | 50 | if (!$this->optimizedRelay) { |
| 51 | 51 | $this->relay->send($header, Relay::PAYLOAD_CONTROL | Relay::PAYLOAD_RAW); |
| 52 | 52 | } |