Method run

components/webapi/src/routes/ws.rs:53–93

(&mut self)

    }

    async fn run(&mut self) {
        let mut ping_ticker = tokio::time::interval(Duration::from_secs(30));

        loop {
            // SelectAll returns Ready(None) when empty
            // so if we didn't have this check this thread
            // would get pinned at 100%
            if !self.active_log_streams.is_empty() {
                tokio::select! {
                    item = self.active_log_streams.next() => {
                        if !self.handle_log_stream_item(item).await {
                            return;
                        }
                    },
                    ws = self.socket.recv() => {
                        if !self.handle_ws_rcv(ws).await {
                            return;
                        }
                    },
                    _ = ping_ticker.tick() => {
                        if !self.send_ping().await{
                            return;
                        }
                    },
                }
            } else {
                tokio::select! {
                    ws = self.socket.recv() => {
                        if !self.handle_ws_rcv(ws).await {
                            return;
                        }
                    },
                    _ = ping_ticker.tick() => {
                        if !self.send_ping().await{
                            return;
                        }
                    },
                }
            }
        }
    }

    async fn handle_log_stream_item(&mut self, item: Option<Result<LogEntry, SseError>>) -> bool {
        match item {