Struct StubStreamingTool 

pub struct StubStreamingTool { /* private fields */ }

Synthetic stream producer for testing the dispatcher’s streaming arm. Emits a deterministic 4-frame sequence per invocation:

  ToolChunk::intermediate("[stub-stream] <name>(")
  ToolChunk::intermediate(<args>)
  ToolChunk::intermediate(")")
  ToolChunk::terminator("", ToolFinishReason::Stop)

Cancel-safe: between every chunk emission, the tool polls ctx.cancel; if fired, the stream short-circuits to a ToolFinishReason::Cancelled terminator chunk. The pre-cancel chunks already emitted reach the consumer; the post-cancel chunks are skipped. D5 p95 ≤100ms invariant honored at the chunk boundary.

Implementations

impl StubStreamingTool

pub fn new(name: String) -> Self

Construct a new stub streaming tool with the given name.

Trait Implementations

impl Tool for StubStreamingTool

fn execute<'life0, 'async_trait>( &'life0 self, args: String, _ctx: ToolContext, ) -> Pin<Box<dyn Future<Output = ToolResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the tool synchronously. Returns a single materialized ToolResult. EVERY tool MUST implement this method (no default — there’s no sensible default execute).

fn stream<'life0, 'async_trait>( &'life0 self, args: String, ctx: ToolContext, ) -> Pin<Box<dyn Future<Output = ToolStream> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stream the tool’s output as a sequence of ToolChunks.

fn is_streaming(&self) -> bool

Whether this tool is a stream producer. Default: false.