@@ -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 | } |