Merge pull request repejota#109 from ingosus/enc

Fixed unnecessary extra encoding

Author: repejota

src/Nats/EncodedConnection.php

@@ -31,21 +31,6 @@ public function __construct(ConnectionOptions $options = null, Encoder $encoder
         parent::__construct($options);
     }
 
-    /**
-     * Request does a request and executes a callback with the response.
-     *
-     * @param string   $subject  Message topic.
-     * @param string   $payload  Message data.
-     * @param \Closure $callback Closure to be executed as callback.
-     *
-     * @return void
-     */
-    public function request($subject, $payload, \Closure $callback)
-    {
-        $payload = $this->encoder->encode($payload);
-        parent::request($subject, $payload, $callback);
-    }
-
     /**
      * Publish publishes the data argument to the given subject.
      *

test/Encoders/JSONEncoderTest.php

@@ -57,5 +57,7 @@ function ($res) {
                 $this->assertEquals('Hello, McFly !!!', $res->getBody());
             }
         );
+        
+        $this->c->wait(1);
     }
 }

test/Encoders/PHPEncoderTest.php

@@ -57,5 +57,7 @@ function ($res) {
                 $this->assertEquals('Hello, McFly !!!', $res->getBody());
             }
         );
+        
+        $this->c->wait(1);
     }
 }

test/Encoders/YAMLEncoderTest.php

@@ -61,5 +61,7 @@ function ($res) {
                 $this->assertEquals('Hello, McFly !!!', $res->getBody());
             }
         );
+        
+        $this->c->wait(1);
     }
 }