Struct BatchingTransport 

pub struct BatchingTransport { /* private fields */ }

Auto-batching transport wrapper.

Sends a flush task in the background that groups pending requests into a single batch call every window milliseconds.

Implementations

impl BatchingTransport

pub fn new( inner: Arc<dyn RpcTransport>, window: Duration, ) -> Arc<BatchingTransport>

Create a new batching transport wrapping inner.

Trait Implementations

impl RpcTransport for BatchingTransport

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

where 'life0: 'async_trait, BatchingTransport: 'async_trait,

Send a single JSON-RPC request and return the response.

fn health(&self) -> HealthStatus

Return the current health status of this transport.

fn url(&self) -> &str

Return the transport’s identifier (URL or name).

fn send_batch<'life0, 'async_trait>( &'life0 self, reqs: Vec<JsonRpcRequest>, ) -> Pin<Box<dyn Future<Output = Result<Vec<JsonRpcResponse>, TransportError>> + Send + 'async_trait>>

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

Send a batch of JSON-RPC requests.

fn call<'life0, 'life1, 'async_trait, T>( &'life0 self, id: u64, method: &'life1 str, params: Vec<Value>, ) -> Pin<Box<dyn Future<Output = Result<T, TransportError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sized + 'async_trait, T: 'async_trait + DeserializeOwned,

Convenience: call a method and deserialize the result.