@@ -60,13 +60,13 @@ |
||
60 | 60 | $methodName = $request->get('method'); |
61 | 61 | |
62 | 62 | $jobManager = $this->get('dtc_queue.manager.job'); |
63 | - $callback = function ($count) { |
|
63 | + $callback = function($count) { |
|
64 | 64 | echo json_encode(['count' => $count]); |
65 | 65 | echo "\n"; |
66 | 66 | flush(); |
67 | 67 | }; |
68 | 68 | |
69 | - $streamingResponse = new StreamedResponse(function () use ($jobManager, $callback, $workerName, $methodName) { |
|
69 | + $streamingResponse = new StreamedResponse(function() use ($jobManager, $callback, $workerName, $methodName) { |
|
70 | 70 | $total = $jobManager->countLiveJobs($workerName, $methodName); |
71 | 71 | echo json_encode(['total' => $total]); |
72 | 72 | echo "\n"; |