Struct SseTransport 

pub struct SseTransport { /* private fields */ }

A transport that wraps an SSE-style message sender

Implementations

impl SseTransport

pub fn new( sender: UnboundedSender<JsonRpcMessage>, receiver: UnboundedReceiver<JsonRpcMessage>, ) -> Self

Trait Implementations

impl ServerTransport for SseTransport

fn write_message<'life0, 'async_trait>( &'life0 mut self, msg: JsonRpcMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Sends a JSON-RPC message (usually a Response)

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

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

Reads a JSON-RPC message (could be a Request or Notification)

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

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

Closes the transport connection