Skip to main content

DispatchPublisher

Trait DispatchPublisher 

Source
pub trait DispatchPublisher: Send + Sync {
    // Required methods
    fn limits(&self) -> QueueLimits;
    fn publish<'a>(
        &'a self,
        records: &'a [PublishedDispatch],
        deadline: Instant,
    ) -> ContractFuture<'a, Vec<PublishResult>>;
}
Expand description

Publish compact dispatch references. Implementations obey both their declared limits and the enclosing deadline. They must bound response bytes before allocation where the transport permits it. Partial responses are per item; absent, malformed, duplicate, or unexpected identities are never confirmation.

Required Methods§

Source

fn limits(&self) -> QueueLimits

Source

fn publish<'a>( &'a self, records: &'a [PublishedDispatch], deadline: Instant, ) -> ContractFuture<'a, Vec<PublishResult>>

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§