@@ -1,5 +1,5 @@ |
||
1 | 1 | <?php |
2 | -declare(strict_types=1); |
|
2 | +declare(strict_types = 1); |
|
3 | 3 | |
4 | 4 | namespace TBolier\RethinkQL\Response; |
5 | 5 |
@@ -47,7 +47,7 @@ |
||
47 | 47 | |
48 | 48 | // TODO: Create factory for instantiation Connection. |
49 | 49 | $this->connections[$name] = new Connection( |
50 | - function () use ($options) { |
|
50 | + function() use ($options) { |
|
51 | 51 | return new Socket( |
52 | 52 | $options |
53 | 53 | ); |
@@ -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); |
@@ -84,7 +84,7 @@ |
||
84 | 84 | $options = new Options(PHPUNIT_CONNECTIONS[$name]); |
85 | 85 | |
86 | 86 | $connection = new Connection( |
87 | - function () use ($options) { |
|
87 | + function() use ($options) { |
|
88 | 88 | return new Socket( |
89 | 89 | $options |
90 | 90 | ); |