codetether-agent 4.7.0-a-002.3

A2A-native AI coding agent for the CodeTether ecosystem
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

//! Bounded async stream reader for bash process output.

use super::types::CapturedStream;
use tokio::io::{AsyncRead, AsyncReadExt};

const BUFFER_BYTES: usize = 8192;

pub(super) async fn read_limited<R>(
    mut stream: R,
    max_bytes: usize,
) -> std::io::Result<CapturedStream>
where
    R: AsyncRead + Unpin,
{
    let mut buf = [0_u8; BUFFER_BYTES];
    let mut kept = Vec::with_capacity(max_bytes.min(BUFFER_BYTES));
    let mut bytes = 0;

    loop {
        let read = stream.read(&mut buf).await?;
        if read == 0 {
            break;
        }
        bytes += read;
        append_kept(&mut kept, &buf[..read], max_bytes);
    }

    Ok(CapturedStream {
        text: String::from_utf8_lossy(&kept).into_owned(),
        bytes,
        truncated: bytes > kept.len(),
    })
}

fn append_kept(kept: &mut Vec<u8>, bytes: &[u8], max_bytes: usize) {
    if kept.len() >= max_bytes {
        return;
    }
    let remaining = max_bytes - kept.len();
    kept.extend_from_slice(&bytes[..bytes.len().min(remaining)]);
}