Struct RawClient 

pub struct RawClient { /* private fields */ }

Available on crate feature async-client only.

A harness session with no interpretation layered on top.

RawClient owns the process and the socket and does exactly three things: the handshake, the initialize exchange, and frame codec. Answering the harness’s tool calls, hooks, and policy checks is the caller’s job — see crate::Client for a version that does that for you.

use antigravity_codes::{HarnessOptions, ModelBuilder, RawClient};
use antigravity_codes::protocol::{InputEvent, OutputEventEvent};

let mut client = RawClient::launch(
    HarnessOptions::new()
        .workspace("/tmp/project")
        .model(ModelBuilder::gemini("gemini-flash-latest", "…")),
)
.await?;

client.send(&InputEvent::user("hello")).await?;
while let Some(event) = client.next_event().await? {
    if let Some(OutputEventEvent::StepUpdate(step)) = event.into_event() {
        println!("{:?}", step.text_or_delta());
    }
}

Implementations

impl RawClient

pub async fn launch(options: HarnessOptions) -> Result<Self>

Launches a harness, connects, and completes the initialize exchange.

pub fn initialize_response(&self) -> &InitializeConversationResponse

The harness’s reply to initialize: the conversation id, any replayed history, and cumulative usage for a resumed session.

pub fn cascade_id(&self) -> Option<&str>

The conversation id, which the harness calls a “cascade id”.

pub fn harness(&self) -> &Harness

The running process, for its stderr tail and port.

pub async fn send(&mut self, event: &InputEvent) -> Result<()>

Sends one frame.

pub async fn next_event(&mut self) -> Result<Option<OutputEvent>>

Reads the next frame, or None once the harness has closed the socket.

Non-text frames (pings, pongs, the close frame itself) are handled and skipped rather than surfaced.

pub fn is_closed(&self) -> bool

True once the socket has closed in either direction.

pub async fn shutdown(self) -> Result<()>

Asks the harness to end the session, waits for it to acknowledge, then stops the process.

The acknowledgement matters: the harness flushes conversation state to its storage directory on the way out, so killing it early loses the transcript a later cascade_id resume would have replayed.

Trait Implementations

impl Debug for RawClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.