Struct SseTransport 

pub struct SseTransport { /* private fields */ }

SSE 传输 - 通过 HTTP Server-Sent Events 通信

Implementations

impl SseTransport

pub fn new( name: impl Into<String>, base_url: impl Into<String>, timeout_ms: Option<u64>, ) -> Self

创建 SSE 传输

Trait Implementations

impl Transport for SseTransport

fn send<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

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

发送请求并等待响应

fn notify<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

发送通知（无需响应）

fn receive<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

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

接收一条消息

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

关闭连接