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
27
28
29
30
31
32

//! Streaming fallback — delegates to non-streaming [`complete`].

use anyhow::Result;
use futures::stream::BoxStream;

use super::runner::TetherScriptProvider;
use crate::provider::{CompletionRequest, StreamChunk};

/// Complete via non-streaming, emit as a single-chunk stream.
pub async fn complete_stream(
    provider: &TetherScriptProvider,
    req: CompletionRequest,
) -> Result<BoxStream<'static, StreamChunk>> {
    let resp = super::complete::complete(provider, req).await?;
    let text = resp
        .message
        .content
        .iter()
        .filter_map(|p| match p {
            crate::provider::ContentPart::Text { text } => Some(text.clone()),
            _ => None,
        })
        .collect::<Vec<_>>()
        .join("");
    let chunks = vec![
        StreamChunk::Text(text),
        StreamChunk::Done {
            usage: Some(resp.usage),
        },
    ];
    Ok(Box::pin(futures::stream::iter(chunks)))
}