4o1x5/bunbun-worker
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

lib.rs handled unwraps for errored deliveries

Browse source
This commit is contained in:
2005 2024-10-25 23:38:19 +02:00
parent b0fc4e69e2
commit d0eba8fa34
1 changed files with 16 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/lib.rs
View file

@ -241,10 +241,15 @@ impl BunBunWorker {
consumer consumer
.for_each_concurrent(None, move |delivery| { .for_each_concurrent(None, move |delivery| {
let handler = Arc::clone(&handler); let handler = Arc::clone(&handler);
// TODO handle unwrap of delivery
let delivery = delivery.unwrap();
async move { async move {
handler(delivery).await; match delivery {
Err(error) => {
tracing::warn!("Received bad msg: {}", error);
}
Ok(delivery) => {
handler(delivery).await;
}
}
} }
}) })
.await; .await;
@ -263,10 +268,15 @@ impl BunBunWorker {
consumer consumer
.for_each_concurrent(None, move |delivery| { .for_each_concurrent(None, move |delivery| {
let handler = Arc::clone(&handler); let handler = Arc::clone(&handler);
// TODO handle unwrap of delivery
let delivery = delivery.unwrap();
async move { async move {
handler(delivery).await; match delivery {
Err(error) => {
tracing::warn!("Received bad msg: {}", error);
}
Ok(delivery) => {
handler(delivery).await;
}
}
} }
}) })
.await; .await;