@@ -13,7 +13,7 @@  | 
                                                    ||
| 13 | 13 | * - string $exchange  | 
                                                        
| 14 | 14 | * - string $routingKey  | 
                                                        
| 15 | 15 | */  | 
                                                        
| 16 | - public function foreach(callable $consume): void;  | 
                                                        |
| 16 | + public function foreach (callable $consume): void;  | 
                                                        |
| 17 | 17 | |
| 18 | 18 | /**  | 
                                                        
| 19 | 19 | * Number of messages to process  | 
                                                        
@@ -50,7 +50,7 @@  | 
                                                    ||
| 50 | 50 | /**  | 
                                                        
| 51 | 51 |       * {@inheritdoc} | 
                                                        
| 52 | 52 | */  | 
                                                        
| 53 | - public function foreach(callable $consume): void  | 
                                                        |
| 53 | + public function foreach (callable $consume): void  | 
                                                        |
| 54 | 54 |      { | 
                                                        
| 55 | 55 |          if ($this->canceled) { | 
                                                        
| 56 | 56 | return;  | 
                                                        
@@ -10,7 +10,7 @@  | 
                                                    ||
| 10 | 10 | /**  | 
                                                        
| 11 | 11 |       * {@inheritdoc} | 
                                                        
| 12 | 12 | */  | 
                                                        
| 13 | - public function foreach(callable $consume): void  | 
                                                        |
| 13 | + public function foreach (callable $consume): void  | 
                                                        |
| 14 | 14 |      { | 
                                                        
| 15 | 15 | //pass  | 
                                                        
| 16 | 16 | }  | 
                                                        
@@ -28,7 +28,7 @@  | 
                                                    ||
| 28 | 28 | /**  | 
                                                        
| 29 | 29 |       * {@inheritdoc} | 
                                                        
| 30 | 30 | */  | 
                                                        
| 31 | - public function foreach(callable $consume): void  | 
                                                        |
| 31 | + public function foreach (callable $consume): void  | 
                                                        |
| 32 | 32 |      { | 
                                                        
| 33 | 33 |          $this->consumer->foreach(function(Message $message, ...$args) use ($consume): void { | 
                                                        
| 34 | 34 |              try { |