* while($task = $consumer->waitTask()) { * // Do something with received $task * var_dump($task); * } * */ public function waitTask(): ?ReceivedTaskInterface; }