tbolier / php-rethink-ql

src/Connection/Registry.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
 
         // TODO: Create factory for instantiation Connection.
         $this->connections[$name] = new Connection(
-            function () use ($options) {
+            function() use ($options) {
                 return new Socket(
                     $options
                 );

test/integration/AbstractTestCase.php

Spacing +1 added lines, -1 removed lines

@@ -84,7 +84,7 @@
         $options = new Options(PHPUNIT_CONNECTIONS[$name]);
 
         $connection = new Connection(
-            function () use ($options) {
+            function() use ($options) {
                 return new Socket(
                     $options
                 );

src/Response/Cursor.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
         int $token,
         ResponseInterface $response,
         MessageInterface $message
-    ) {
+    ){
         $this->connection = $connection;
         $this->token = $token;
         $this->addResponse($response);

src/Connection/Connection.php

Spacing +1 added lines, -1 removed lines

@@ -65,7 +65,7 @@
         string $dbName,
         SerializerInterface $querySerializer,
         SerializerInterface $responseSerializer
-    ) {
+    ){
         $this->streamWrapper = $streamWrapper;
         $this->dbName = $dbName;
         $this->handshake = $handshake;

src/Query/Operation/Insert.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
         MessageInterface $message,
         QueryInterface $query,
         array $documents
-    ) {
+    ){
         parent::__construct($rethink, $message);
 
         $this->query = $query;

src/Query/Operation/Get.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
         MessageInterface $message,
         QueryInterface $query,
         $key
-    ) {
+    ){
         parent::__construct($rethink, $message);
 
         $this->query = $query;

src/Query/Operation/Update.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
         MessageInterface $message,
         QueryInterface $query,
         array $elements
-    ) {
+    ){
         parent::__construct($rethink, $message);
 
         $this->query = $query;

src/Query/Operation/Filter.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
         MessageInterface $message,
         QueryInterface $query,
         array $predicate
-    ) {
+    ){
         parent::__construct($rethink, $message);
 
         $this->query = $query;

test/unit/Connection/ConnectionTestCase.php

Spacing +3 added lines, -3 removed lines

@@ -49,7 +49,7 @@ 
         parent::setUp();
 
         $this->stream = Mockery::mock(StreamInterface::class);
-        $this->streamWrapper = function () {
+        $this->streamWrapper = function(){
             return $this->stream;
         };
 
@@ -105,7 +105,7 @@ 
      */
     protected function catchStreamWrite(\stdClass $buffer)
     {
-        $this->stream->shouldReceive('write')->andReturnUsing(function ($string) use ($buffer) {
+        $this->stream->shouldReceive('write')->andReturnUsing(function($string) use ($buffer) {
             $buffer->data = $string;
 
             return 20;
@@ -116,7 +116,7 @@ 
 
     protected function catchStreamRead(int $bytes, \stdClass $buffer): void
     {
-        $this->stream->shouldReceive('read')->once()->with($bytes)->andReturnUsing(function ($bytes) use (&$buffer) {
+        $this->stream->shouldReceive('read')->once()->with($bytes)->andReturnUsing(function($bytes) use (&$buffer) {
             $data = '';
             if (isset($buffer->data)) {
                 $data = substr($buffer->data, 0, $bytes);