Method read

src/crates/services/services-integrations/src/remote_ssh/manager.rs:2479–2496

Read data from PTY. Blocks until data is available, PTY closes, or an error occurs. Returns Ok(Some(bytes)) for data, Ok(None) for clean close, Err for errors.

(&self)

    /// Blocks until data is available, PTY closes, or an error occurs.
    /// Returns Ok(Some(bytes)) for data, Ok(None) for clean close, Err for errors.
    pub async fn read(&self) -> anyhow::Result<Option<Vec<u8>>> {
        let mut channel = self.channel.lock().await;
        loop {
            match channel.wait().await {
                Some(russh::ChannelMsg::Data { data }) => return Ok(Some(data.to_vec())),
                Some(russh::ChannelMsg::ExtendedData { data, .. }) => {
                    return Ok(Some(data.to_vec()));
                }
                Some(russh::ChannelMsg::Eof) | Some(russh::ChannelMsg::Close) => return Ok(None),
                Some(russh::ChannelMsg::ExitStatus { .. }) => return Ok(None),
                Some(_) => {
                    // WindowAdjust, Success, RequestSuccess, etc. — skip and keep reading
                    continue;
                }
                None => return Ok(None),
            }
        }
    }

    /// Close PTY session
    pub async fn close(self) -> anyhow::Result<()> {