Struct McpProgressSink 

pub struct McpProgressSink { /* private fields */ }

Sink used for a single in-flight tools/call JSON-RPC request.

tx is the SSE stream’s outbound channel. If requested_token is Some, the client supplied a progressToken in the request’s _meta; we reuse it so the client can correlate events. Otherwise we mint one.

session_events is the session-wide broadcast sender (see super::session). tool_name is stamped onto each ProgressEvent so session subscribers can show which Construct tool is doing work (e.g. notion, jira, …).

Implementations

impl McpProgressSink

pub fn new(tx: UnboundedSender<Value>, requested_token: Option<u64>) -> Self

Per-request-only sink (no session broadcast). Kept for backwards compatibility with existing tests; production code should prefer Self::with_session.

pub fn with_session( tx: UnboundedSender<Value>, requested_token: Option<u64>, session_events: Sender<ProgressEvent>, tool_name: impl Into<String>, ) -> Self

Full-fat sink that fans out to both the per-request SSE stream and the session-wide broadcast channel.

Trait Implementations

impl ProgressSink for McpProgressSink

fn new_token(&self) -> ProgressToken

Allocate a fresh progress token for a new operation.

fn notify( &self, token: ProgressToken, progress: u64, total: Option<u64>, message: Option<&str>, )

Emit a progress event.