async_lapin/
lib.rs

1use lapin::ConnectionProperties;
2
3// ConnectionProperties extension
4
5#[deprecated(note = "use async-reactor-trait directly instead")]
6pub trait LapinAsyncIoExt {
7    #[deprecated(note = "use async-reactor-trait directly instead")]
8    fn with_async_io(self) -> Self
9    where
10        Self: Sized,
11    {
12        self.with_async_io_reactor()
13    }
14
15    #[deprecated(note = "use async-reactor-trait directly instead")]
16    fn with_async_io_reactor(self) -> Self
17    where
18        Self: Sized;
19}
20
21impl LapinAsyncIoExt for ConnectionProperties {
22    fn with_async_io_reactor(self) -> Self {
23        self.with_reactor(async_reactor_trait::AsyncIo)
24    }
25}