Minor tweaks

Author: repejota

examples/connect.php

@@ -1,13 +1,6 @@
 <?php
 require_once __DIR__.'/../vendor/autoload.php';
 
-$connectionOptions = new \Nats\ConnectionOptions(
-    [
-     'host' => '127.0.0.1',
-     'port' => 4222,
-    ]
-);
-
-$c = new Nats\Connection($connectionOptions);
+$c = new Nats\Connection();
 $c->connect();
 $c->close();

examples/ping.php

@@ -9,4 +9,6 @@
 $c = new Nats\Connection($connectionOptions);
 $c->connect();
 
+
+// TODO ping is not public.
 $c->ping();

examples/pubsub/pub.php

@@ -0,0 +1,9 @@
+<?php
+require_once __DIR__.'/../../vendor/autoload.php';
+
+$client = new \Nats\Connection();
+$client->connect();
+
+// Simple Publisher.
+$client->publish('foo', 'bar');
+$client->close();

examples/pubsub/pubsub.php

@@ -18,3 +18,5 @@ function ($message) {
 
 // Wait for 1 message.
 $client->wait(1);
+
+$client->close();

examples/pubsub/sub.php

@@ -0,0 +1,15 @@
+<?php
+require_once __DIR__.'/../../vendor/autoload.php';
+
+$client = new \Nats\Connection();
+$client->connect();
+
+// Simple Subscriber.
+$client->subscribe(
+    'foo',
+    function ($message) {
+        printf("Data: %s\r\n", $message->getBody());
+    }
+);
+
+$client->close();

examples/reqres/request.php

@@ -0,0 +1,17 @@
+<?php
+require_once __DIR__.'/../../vendor/autoload.php';
+
+$client = new \Nats\Connection();
+$client->connect();
+
+// Simple Publisher.
+// Request.
+$client->request(
+    'foo',
+    'Marty McFly',
+    function ($message) {
+        echo $message->getBody();
+    }
+);
+
+$client->close();

src/Nats/Connection.php

@@ -464,6 +464,7 @@ public function request($subject, $payload, \Closure $callback)
             $inbox,
             $callback
         );
+
         $msg = 'PUB '.$subject.' '.$inbox.' '.strlen($payload);
         $this->send($msg."\r\n".$payload);
         $this->pubs += 1;

src/Nats/EncodedConnection.php

@@ -1,6 +1,8 @@
 <?php
 namespace Nats;
 
+use Nats\Encoders\Encoder;
+
 /**
  * Class EncodedConnection
  *
@@ -23,7 +25,7 @@ class EncodedConnection extends Connection
      * @param ConnectionOptions           $options Connection options object.
      * @param \Nats\Encoders\Encoder|null $encoder Encoder to use with the payload.
      */
-    public function __construct(ConnectionOptions $options = null, \Nats\Encoders\Encoder $encoder = null)
+    public function __construct(ConnectionOptions $options = null, Encoder $encoder = null)
     {
         $this->encoder = $encoder;
         parent::__construct($options);