File tree Expand file tree Collapse file tree 1 file changed +10
-2
lines changed Expand file tree Collapse file tree 1 file changed +10
-2
lines changed Original file line number Diff line number Diff line change 77use Mammatus \LifeCycleEvents \Shutdown ;
88use Mammatus \Queue \Generated \AbstractList ;
99use Psr \Log \LoggerInterface ;
10+ use React \EventLoop \Loop ;
1011use Throwable ;
1112use WyriHaximus \Broadcast \Contracts \Listener ;
1213use WyriHaximus \PSR3 \ContextLogger \ContextLogger ;
@@ -30,7 +31,8 @@ public function stop(Shutdown $event): void
3031
3132 public function run (string $ className ): int
3233 {
33- return await (async (function (string $ className ): int {
34+ $ exitCode = 2 ;
35+ async (function (string $ className ): int {
3436 $ logger = new ContextLogger ($ this ->logger , ['worker ' => $ className ]);
3537 try {
3638 $ promises = [];
@@ -52,6 +54,12 @@ public function run(string $className): int
5254 }
5355
5456 return $ exitCode ;
55- })($ className ));
57+ })($ className )->then (static function (int $ resultingExitCode ) use (&$ exitCode ): void {
58+ $ exitCode = $ resultingExitCode ;
59+ });
60+
61+ Loop::run ();
62+
63+ return $ exitCode ;
5664 }
5765}
You can’t perform that action at this time.
0 commit comments