@@ -196,7 +196,7 @@ |
||
| 196 | 196 | |
| 197 | 197 | $loop->addPeriodicTimer( |
| 198 | 198 | Constants::TIME_TICK_INTERVAL, |
| 199 | - function () use ($closure, $messageHydrate, $loop) { |
|
| 199 | + function() use ($closure, $messageHydrate, $loop) { |
|
| 200 | 200 | $transporter = new StreamCommandCallTransporter( |
| 201 | 201 | [ |
| 202 | 202 | 'command' => Constants::COMMAND_XRANGE, |
@@ -20,7 +20,7 @@ |
||
| 20 | 20 | */ |
| 21 | 21 | public function setUp() : void |
| 22 | 22 | { |
| 23 | - $connector = \Mockery::mock(ClientRedisStreamPhpInterface::class); |
|
| 23 | + $connector = \Mockery::mock(ClientRedisStreamPhpInterface::class); |
|
| 24 | 24 | $this->client = new Client($connector); |
| 25 | 25 | } |
| 26 | 26 | |
@@ -6,6 +6,6 @@ |
||
| 6 | 6 | { |
| 7 | 7 | |
| 8 | 8 | public function handle($payload) { |
| 9 | - echo 'привет я DemoListener - ' . $payload; |
|
| 9 | + echo 'привет я DemoListener - ' . $payload; |
|
| 10 | 10 | } |
| 11 | 11 | } |
| 12 | 12 | \ No newline at end of file |