26 releases (3 stable)
2.0.0 | Feb 2, 2022 |
---|---|
1.1.0 | Nov 21, 2020 |
1.0.0 | Oct 31, 2020 |
0.5.1 | Oct 16, 2020 |
0.3.1 | Jul 23, 2020 |
61 downloads per month
355KB
9K
SLoC
Lapin integration with smol
This crate integrates lapin with smol by using smol's executor inside of lapin for its internal operations and for consumer delegates.
use lapinou::*;
use lapin::{Connection, ConnectionProperties, Result};
fn main() -> Result<()> {
smol::block_on(async {
let addr = std::env::var("AMQP_ADDR").unwrap_or_else(|_| "amqp://127.0.0.1:5672/%2f".into());
let conn = Connection::connect(&addr, ConnectionProperties::default().with_smol()).await?; // Note the `with_smol()` here
let channel = conn.create_channel().await?;
// Rest of your program
})
}
Dependencies
~8–18MB
~258K SLoC