Struct ToolStreamCall 

pub struct ToolStreamCall {
    pub progress_token: String,
    pub stream: OpenStreamSession,
    pub result: BoxFuture<'static, Result<CallToolResult>>,
    /* private fields */
}

A live CEP-41 tool call: the incremental chunk stream, the eventual final result, and an abort handle.

Fields

progress_token: String

The stringified progressToken correlating the call and its stream.

stream: OpenStreamSession

The async stream of payload chunks (impl Stream<Item = Result<String, OpenStreamError>>).

result: BoxFuture<'static, Result<CallToolResult>>

The final CallToolResult, resolving after the stream closes (deferral).

A flat result: the spawned-task (JoinError) and rmcp (ServiceError) failures are folded into crate::Error, so consumers await once rather than unwrapping a nested Result.

Implementations

impl ToolStreamCall

pub async fn abort(&self, reason: Option<String>)

Consumer cancel: publish an abort frame to the server (so its writer aborts), finalize the local stream, and free the reader registry slot.

Trait Implementations

impl Debug for ToolStreamCall

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

Formats the value using the given formatter.