Removing StreamWrapper from construct in Connection class.

Author: jgil

src/Connection.php

@@ -108,22 +108,31 @@ public function getSubscriptions()
     /**
      * Constructor.
      *
-     * @param ConnectionOptions $options       Connection options object.
-     * @param StreamWrapper     $streamWrapper Wrapper for stream functions. Testing purposes.
+     * @param ConnectionOptions $options Connection options object.
      */
-    public function __construct(ConnectionOptions $options = null, StreamWrapper $streamWrapper = null)
+    public function __construct(ConnectionOptions $options = null)
     {
         $this->pings = 0;
         $this->pubs = 0;
         $this->subscriptions = [];
         $this->options = $options;
-        $this->streamWrapper = $streamWrapper;
+        $this->streamWrapper = new StreamWrapper();
+
         if (is_null($options)) {
             $this->options = new ConnectionOptions();
         }
-        if (is_null($streamWrapper)) {
-            $this->streamWrapper = new StreamWrapper();
-        }
+    }
+
+    /**
+     * Setter for $streamWrapper. For testing purposes.
+     *
+     * @param StreamWrapper $streamWrapper StreamWrapper for testing purposes.
+     *
+     * @return void
+     */
+    public function setStreamWrapper(StreamWrapper $streamWrapper)
+    {
+        $this->streamWrapper = $streamWrapper;
     }
 
     /**

tests/Unit/ConnectionTest.php

@@ -52,7 +52,8 @@ public function setUp()
 
         $streamWrapper->setStreamTimeout(Argument::any(), Argument::any())->willReturn(true);
 
-        $this->c = new Nats\Connection($options, $streamWrapper->reveal());
+        $this->c = new Nats\Connection($options);
+        $this->c->setStreamWrapper($streamWrapper->reveal());
         $this->c->connect();
     }