Trait async_lapin::LapinAsyncIoExt

pub trait LapinAsyncIoExt {
    fn with_async_io_reactor(
        self, 
        spawner: impl Fn(Pin<Box<dyn Future<Output = ()> + Send>>) + Send + Sync + 'static
    ) -> Self
    where
        Self: Sized;

    fn with_async_io(
        self, 
        spawner: impl Fn(Pin<Box<dyn Future<Output = ()> + Send>>) + Send + Sync + 'static
    ) -> Self
    where
        Self: Sized,
    { ... }
}

Required methods

fn with_async_io_reactor(
    self,
    spawner: impl Fn(Pin<Box<dyn Future<Output = ()> + Send>>) + Send + Sync + 'static
) -> Self where
    Self: Sized, 

Loading content...

Provided methods

fn with_async_io(
    self,
    spawner: impl Fn(Pin<Box<dyn Future<Output = ()> + Send>>) + Send + Sync + 'static
) -> Self where
    Self: Sized, 

Loading content...

Implementations on Foreign Types

impl LapinAsyncIoExt for ConnectionProperties

fn with_async_io_reactor(
    self,
    spawner: impl Fn(Pin<Box<dyn Future<Output = ()> + Send>>) + Send + Sync + 'static
) -> Self

Loading content...

Implementors

Loading content...