a3s-code-core 1.11.0

A3S Code Core - Embeddable AI agent library with tool execution
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

//! MCP Transport Layer
//!
//! Provides transport abstraction for MCP communication.
//! - `stdio`: Local process communication via stdin/stdout
//! - `http_sse`: Remote server communication via HTTP + Server-Sent Events

pub mod http_sse;
pub mod stdio;
pub mod streamable_http;

use crate::mcp::protocol::{JsonRpcNotification, JsonRpcRequest, JsonRpcResponse, McpNotification};
use anyhow::Result;
use async_trait::async_trait;
use tokio::sync::mpsc;

/// MCP transport trait
#[async_trait]
pub trait McpTransport: Send + Sync {
    /// Send request and wait for response
    async fn request(&self, request: JsonRpcRequest) -> Result<JsonRpcResponse>;

    /// Send notification (no response expected)
    async fn notify(&self, notification: JsonRpcNotification) -> Result<()>;

    /// Get notification receiver
    fn notifications(&self) -> mpsc::Receiver<McpNotification>;

    /// Close the transport
    async fn close(&self) -> Result<()>;

    /// Check if transport is connected
    fn is_connected(&self) -> bool;
}