@@ -50,7 +50,7 @@ |
||
| 50 | 50 | int $token, |
| 51 | 51 | ResponseInterface $response, |
| 52 | 52 | MessageInterface $message |
| 53 | - ) { |
|
| 53 | + ){ |
|
| 54 | 54 | $this->connection = $connection; |
| 55 | 55 | $this->token = $token; |
| 56 | 56 | $this->addResponse($response); |
@@ -32,7 +32,7 @@ |
||
| 32 | 32 | MessageInterface $message, |
| 33 | 33 | QueryInterface $query, |
| 34 | 34 | $n |
| 35 | - ) { |
|
| 35 | + ){ |
|
| 36 | 36 | parent::__construct($rethink, $message); |
| 37 | 37 | |
| 38 | 38 | $this->query = $query; |
@@ -31,7 +31,7 @@ |
||
| 31 | 31 | MessageInterface $message, |
| 32 | 32 | QueryInterface $query, |
| 33 | 33 | $key |
| 34 | - ) { |
|
| 34 | + ){ |
|
| 35 | 35 | parent::__construct($rethink, $message); |
| 36 | 36 | |
| 37 | 37 | $this->query = $query; |
@@ -49,7 +49,7 @@ discard block |
||
| 49 | 49 | parent::setUp(); |
| 50 | 50 | |
| 51 | 51 | $this->stream = Mockery::mock(StreamInterface::class); |
| 52 | - $this->streamWrapper = function () { |
|
| 52 | + $this->streamWrapper = function(){ |
|
| 53 | 53 | return $this->stream; |
| 54 | 54 | }; |
| 55 | 55 | |
@@ -105,7 +105,7 @@ discard block |
||
| 105 | 105 | */ |
| 106 | 106 | protected function catchStreamWrite(\stdClass $buffer) |
| 107 | 107 | { |
| 108 | - $this->stream->shouldReceive('write')->andReturnUsing(function ($string) use ($buffer) { |
|
| 108 | + $this->stream->shouldReceive('write')->andReturnUsing(function($string) use ($buffer) { |
|
| 109 | 109 | $buffer->data = $string; |
| 110 | 110 | |
| 111 | 111 | return 20; |
@@ -116,7 +116,7 @@ discard block |
||
| 116 | 116 | |
| 117 | 117 | protected function catchStreamRead(int $bytes, \stdClass $buffer): void |
| 118 | 118 | { |
| 119 | - $this->stream->shouldReceive('read')->once()->with($bytes)->andReturnUsing(function ($bytes) use (&$buffer) { |
|
| 119 | + $this->stream->shouldReceive('read')->once()->with($bytes)->andReturnUsing(function($bytes) use (&$buffer) { |
|
| 120 | 120 | $data = ''; |
| 121 | 121 | if (isset($buffer->data)) { |
| 122 | 122 | $data = substr($buffer->data, 0, $bytes); |