Function write_frame

atomic-cli/src/commands/agent/owner.rs:1347–1360

(stream: &mut S, value: &T)

}

async fn write_frame<T, S>(stream: &mut S, value: &T) -> anyhow::Result<()>
where
    T: Serialize,
    S: AsyncWrite + Unpin,
{
    let payload = serde_json::to_vec(value)?;
    if payload.len() > MAX_FRAME_BYTES {
        return Err(anyhow!("database-owner frame exceeds size limit"));
    }
    stream.write_u32(payload.len() as u32).await?;
    stream.write_all(&payload).await?;
    stream.flush().await?;
    Ok(())
}

/// A turn's envelope batch can exceed `MAX_FRAME_BYTES` on its own (a heavy
/// agent turn recovers full tool output), so split it before framing. The