codetether-agent 4.7.0-a-002.4

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

use tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader, Lines};
use tokio::process::{ChildStdin, ChildStdout};

pub fn lines(stdout: ChildStdout) -> Lines<BufReader<ChildStdout>> {
    BufReader::new(stdout).lines()
}

pub async fn write(stdin: &mut ChildStdin, command: &str) -> anyhow::Result<()> {
    stdin.write_all(command.as_bytes()).await?;
    stdin.flush().await?;
    Ok(())
}

pub async fn read_until(
    stdout: &mut Lines<BufReader<ChildStdout>>,
    marker: &str,
) -> anyhow::Result<Vec<String>> {
    let mut lines = Vec::new();
    while let Some(line) = stdout.next_line().await? {
        if line.trim() == marker {
            return Ok(lines);
        }
        lines.push(line);
    }
    anyhow::bail!("PowerShell session closed")
}