@@ -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();  |