Struct HttpSseTransport 

pub struct HttpSseTransport { /* private fields */ }

Implementations

impl HttpSseTransport

pub fn new(endpoint: impl Into<String>, timeout: Duration) -> Self

Trait Implementations

impl Transport for HttpSseTransport

fn capabilities(&self) -> TransportCapabilities

Capability metadata for this transport implementation.

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

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

Write a raw message string without reading a response. Used for notifications and other one-way messages.

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

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

Write a raw message string and read back one response line. Returns None if the response line is empty.

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

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

Shut down the transport gracefully.

fn send_request<'life0, 'life1, 'async_trait>( &'life0 mut self, req: &'life1 JsonRpcRequest, ) -> Pin<Box<dyn Future<Output = Result<JsonRpcResponse, TransportError>> + Send + 'async_trait>>

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

Send a typed JSON-RPC request and get the parsed response.

fn send_notification<'life0, 'life1, 'async_trait>( &'life0 mut self, notif: &'life1 JsonRpcNotification, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

Send a JSON-RPC notification (write-only, no response expected).

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

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

Send a raw string and read one response. Convenience alias for the fuzzer.