Struct ethcontract::batch::CallBatch

pub struct CallBatch<T: Web3BatchTransport> { /* fields omitted */ }

Struct allowing to batch multiple calls into a single Node request

Implementations

impl<T: Web3BatchTransport> CallBatch<T>

pub fn new(inner: T) -> Self

Create a new instance from a BatchTransport

pub fn push(
    &mut self,
    call: CallRequest,
    block: Option<BlockId>
) -> impl Future<Output = Result<Bytes, Web3Error>>

Adds a call request to the current batch. The resulting future can only resolve after the batch has been resolved via execute_all. Explicitly returns a Future instead of being declared async so that we can split the logic into a synchronous and asynchronous section and don’t want to capture &mut self in the future. Panics, if the batch is dropped before executing.

pub async fn execute_all(self, batch_size: usize)

Execute and resolve all enqueued CallRequests in a batched RPC call, chunk_size requests per roundtrip. Top level request failures will be forwarded to the individual requests.