Method run

components/scheduler/src/broker_client.rs:43–53

(mut self)

impl BrokerConn {
    async fn run(mut self) -> std::io::Result<()> {
        let _ = self.scheduler_tx.send(SchedulerCommand::BrokerConnected);

        loop {
            let next: BrokerEvent = simpleproto::read_message(&mut self.stream).await?;
            match self.handle_broker_message(next).await? {
                ContinueState::Continue => {}
                ContinueState::Stop => return Ok(()),
            }
        }
    }

    #[instrument(skip(self, message))]
    async fn handle_broker_message(