Struct DefaultBuilder

pub struct DefaultBuilder<M: Send + Sync, H: Send + Sync, C: Send + Sync, F: Send> { /* private fields */ }

Implementations

impl<M, H, C, F> DefaultBuilder<M, H, C, F>

where M: Message, H: Sync + Send + 'static, F: Send + Future<Output = Result<H, Error>> + 'static, C: Sync + Send + Fn(u32, u32) -> F + 'static,

pub fn new(queue_size: usize, callback: C) -> Self

pub fn ordered(self, buf: Option<u32>) -> Self

pub fn stream_per_message(self) -> Self

pub fn tasks(self, tasks: u32) -> Self

Trait Implementations

impl<M, H, C, F> Builder<M> for DefaultBuilder<M, H, C, F>

where M: Message, H: Sync + Send + 'static, F: Send + Future<Output = Result<H, Error>> + 'static, C: Sync + Send + Fn(u32, u32) -> F + 'static,

type Context = H

async fn build( &self, stream_id: u32, task_id: u32, ) -> Result<Self::Context, Error>

fn config(&self, _stream_id: u32) -> Config

impl<M: Send + Sync, H: Send + Sync, C: Send + Sync, F: Send> Sync for DefaultBuilder<M, H, C, F>