Method try_recv

crates/chat-cli/src/cli/chat/parser.rs:361–382

(&mut self)

    }

    async fn try_recv(&mut self) {
        loop {
            if self.ended {
                trace!("response stream has ended");
                return;
            }

            let cancel_token = self.cancel_token.clone();
            tokio::select! {
                res = self.recv() => {
                    let _ = self.event_tx.send(res).await.map_err(|err| error!(?err, "failed to send event to channel"));
                },
                _ = cancel_token.cancelled() => {
                    debug!("response parser was cancelled");
                    let err = self.error(RecvErrorKind::Cancelled);
                    *self.request_metadata.lock().await = Some(err.request_metadata.clone());
                    let _ = self.event_tx.send(Err(err)).await.map_err(|err| error!(?err, "failed to send error to channel"));
                    return;
                },
            }
        }
    }

    /// Consumes the associated [ConverseStreamResponse] until a valid [ResponseEvent] is parsed.
    async fn recv(&mut self) -> Result<ResponseEvent, RecvError> {