Fixed errors with replies on request/response

Author: repejota

README.md

@@ -78,6 +78,38 @@ $sid = $client->subscribe("sayhello", function ($res) {
     $res->reply("Hello, " . $res->getBody() . " !!!");
 });
 
+# Wait for 1 message
+$client->wait(1);
+```
+
+### Encoded Connections
+
+```php
+$encoder = new \Nats\Encoders\JSONEncoder();
+$options = new \Nats\ConnectionOptions();
+$client = new \Nats\EncodedConnection($options, $encoder);
+$client->connect();
+
+# Simple Publisher
+$client->publish("foo", array("one", "two"));
+
+# Simple Subscriber
+$callback = function($payload)
+{
+    printf("Data: %s\r\n", var_dump($payload));
+};
+$client->subscribe("foo", $callback);
+
+# Request
+$client->request('sayhello', ['foo', 'Marty McFly'], function ($response) {
+    echo 'Hello '.$response->getBody()[1].' !!!';
+});
+
+# Responding to requests
+$sid = $client->subscribe("sayhello", function ($res) {
+    $res->reply("Hello, " . $res->getBody() . " !!!");
+});
+
 
 
 # Wait for 1 message

examples/pubsub/jsonencodedpub.php

@@ -0,0 +1,37 @@
+<?php
+require_once __DIR__.'/../../vendor/autoload.php';
+
+$encoder = new \Nats\Encoders\JSONEncoder();
+$options = new \Nats\ConnectionOptions();
+$client = new \Nats\EncodedConnection($options, $encoder);
+$client->connect();
+
+// Publish Subscribe
+
+
+# Simple Subscriber
+$callback = function($payload)
+{
+    printf("Data: %s\r\n", $payload->getBody()[1]);
+};
+$client->subscribe("foo", $callback);
+
+# Simple Publisher
+$client->publish("foo", ["foo", "bar"]);
+
+# Wait for 1 message
+$client->wait(1);
+
+// Request Response
+
+
+# Responding to requests
+$sid = $client->subscribe("sayhello", function ($message) {
+    $message->reply("Reply: Hello, " . $message->getBody()[1] . " !!!");
+});
+
+# Request
+$client->request('sayhello', ["foo", "McFly"], function ($message) {
+    echo $message->getBody();
+});
+

examples/pubsub/jsonencodedpubsub.php

@@ -0,0 +1,32 @@
+<?php
+require_once __DIR__.'/../../vendor/autoload.php';
+
+$client = new \Nats\Connection();
+$client->connect();
+
+// Publish Subscribe
+
+# Simple Subscriber
+$callback = function($message)
+{
+    printf("Data: %s\r\n", $message->getBody());
+};
+$client->subscribe("foo", $callback);
+
+# Simple Publisher
+$client->publish("foo", "foo bar");
+
+# Wait for 1 message
+$client->wait(1);
+
+// Request Response
+
+# Responding to requests
+$sid = $client->subscribe("sayhello", function ($message) {
+    $message->reply("Reply: Hello, " . $message->getBody() . " !!!");
+});
+
+# Request
+$client->request('sayhello', 'Marty McFly', function ($message) {
+    echo $message->getBody();
+});

examples/pubsub/jsonencodedsub.php

@@ -366,8 +366,6 @@ private function handleMSG($line)
         } else {
             throw Exception::forSubscriptionCallbackInvalid($sid);
         }
-
-        return;
     }
 
     /**
@@ -436,7 +434,7 @@ public function request($subject, $payload, \Closure $callback)
         $this->send($msg."\r\n".$payload);
         $this->pubs += 1;
 
-        $this->wait(1);
+        $this->wait(2);
     }
 
     /**

examples/pubsub/pub.php

@@ -110,7 +110,6 @@ function ($res) {
              'McFly',
             ],
             function ($res) {
-                var_dump($res);
                 $this->assertEquals('Hello, McFly !!!', $res->getBody());
             }
         );