@@ -14,20 +14,20 @@ |
||
| 14 | 14 | public function __construct(ConnectionInterface $src) |
| 15 | 15 | { |
| 16 | 16 | $this->src = $src; |
| 17 | - $src->on('data', function ($data) { |
|
| 17 | + $src->on('data', function($data) { |
|
| 18 | 18 | $this->buffer .= $data; |
| 19 | 19 | if ($this->dst) { |
| 20 | 20 | $this->dst->write($this->buffer); |
| 21 | 21 | $this->buffer = ''; |
| 22 | 22 | } |
| 23 | 23 | }); |
| 24 | - $src->on('end', function () { |
|
| 24 | + $src->on('end', function() { |
|
| 25 | 25 | $this->end = true; |
| 26 | 26 | if ($this->dst) { |
| 27 | 27 | $this->dst->end(); |
| 28 | 28 | } |
| 29 | 29 | }); |
| 30 | - $src->on('error', function () { |
|
| 30 | + $src->on('error', function() { |
|
| 31 | 31 | $this->end = true; |
| 32 | 32 | if ($this->dst) { |
| 33 | 33 | $this->dst->end(); |