@@ -4,7 +4,7 @@ |
||
| 4 | 4 | require "vendor/autoload.php"; |
| 5 | 5 | |
| 6 | 6 | $rpc = new Goridge\RPC( |
| 7 | - new Goridge\SocketRelay("127.0.0.1", 6001) |
|
| 7 | + new Goridge\SocketRelay("127.0.0.1", 6001) |
|
| 8 | 8 | ); |
| 9 | 9 | |
| 10 | 10 | echo $rpc->call("App.Hi", "Antony"); |
@@ -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 | } |