Struct HttpBatchTransport 

pub struct HttpBatchTransport { /* private fields */ }

HTTP Batch transport collects messages and sends them as a single HTTP request

Implementations

impl HttpBatchTransport

pub fn new(endpoint: String) -> Self

pub async fn execute(&mut self) -> Result<(), TransportError>

Execute the batch - send all queued messages and receive responses This is a placeholder implementation that will need an actual HTTP client

pub fn endpoint(&self) -> &str

pub fn pending_outgoing(&self) -> usize

pub fn pending_incoming(&self) -> usize

Trait Implementations

impl RpcTransport for HttpBatchTransport

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

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

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

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

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

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