Struct BobStreamParser 

pub struct BobStreamParser { /* private fields */ }

Stateful wrapper over parse_bob_line for a single bob run. bob streams its reasoning inline as <thinking>…</thinking> within the assistant message content (grounded in a real run — the tags arrive as their own deltas), so routing that reasoning to the Thinking stream requires tracking the open/closed state across lines. The per-line dispatch (text / tool events / answer) stays in parse_bob_line; this only re-routes assistant text through the thinking-tag state machine. One instance per run (see BobHarness).

Implementations

impl BobStreamParser

pub fn parse_line(&mut self, line: &str) -> ParsedLine

Parse one stdout line, routing any assistant text through the <thinking> state machine into ParsedLine::text / ParsedLine::thinking.

Examples found in repository

examples/replay_bob.rs (line 17)

fn main() {
    let path = std::env::args().nth(1).expect("usage: replay_bob <out.jsonl>");
    let file = std::fs::File::open(&path).expect("open file");
    let mut parser = BobStreamParser::default();
    let (mut text, mut thinking, mut tools) = (String::new(), String::new(), Vec::new());
    for line in std::io::BufReader::new(file).lines() {
        let parsed = parser.parse_line(&line.unwrap());
        if let Some(t) = parsed.text {
            text.push_str(&t);
        }
        if let Some(t) = parsed.thinking {
            thinking.push_str(&t);
        }
        if let Some(ts) = parsed.tool_start {
            tools.push(format!("ToolStart({})", ts.name));
        }
        if parsed.tool_end.is_some() {
            tools.push("ToolEnd".to_owned());
        }
    }
    println!("=== VISIBLE TEXT (host renders this as the message) ===\n{text}\n");
    println!("contains '[using tool' ? {}", text.contains("[using tool"));
    println!("contains '<thinking>'  ? {}", text.contains("<thinking>"));
    println!("\n=== THINKING (routed to its own section) ===\n{}", thinking.trim());
    println!("\n=== TOOL EVENTS ===");
    for t in &tools {
        println!("  {t}");
    }
}

Trait Implementations

impl Debug for BobStreamParser

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

Formats the value using the given formatter.

impl Default for BobStreamParser

fn default() -> BobStreamParser

Returns the “default value” for a type.