fix(gateway): use try_send for events

This commit is contained in:
asleepyskye 2025-08-15 16:48:22 -04:00
parent ae9d818f4b
commit 621889a6c2

View file

@ -227,7 +227,9 @@ pub async fn runner(
}
if runtime_config.exists(RUNTIME_CONFIG_KEY_EVENT_TARGET).await {
tx.send((shard.id(), event, raw_event)).await.unwrap();
if let Err(error) = tx.try_send((shard.id(), event, raw_event)) {
tracing::error!(?error, "error sending shard event");
}
}
}
}