ErrorNoInternet/ErrorNoWatcher
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: call event listeners in tasks

Browse Source
This commit is contained in:
Ryan 2025-03-06 17:59:42 -05:00
parent 9ce4a7aa1f
commit 9001cd9701
Signed by: ErrorNoInternet
GPG Key ID: 2486BFB7B1E6A4A3
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/events.rs
View File

@ -176,12 +176,19 @@ pub async fn handle_event(client: Client, event: Event, state: State) -> anyhow:
Ok(())
}
async fn call_listeners<T: Clone + IntoLuaMulti>(state: &State, event_type: &str, data: T) {
if let Some(listeners) = state.event_listeners.read().await.get(event_type) {
async fn call_listeners<T: Clone + IntoLuaMulti + Send + 'static>(
state: &State,
event_type: &'static str,
data: T,
) {
if let Some(listeners) = state.event_listeners.read().await.get(event_type).cloned() {
for (id, callback) in listeners {
if let Err(error) = callback.call_async::<()>(data.clone()).await {
let data = data.clone();
tokio::spawn(async move {
if let Err(error) = callback.call_async::<()>(data).await {
error!("failed to call lua event listener {id} for {event_type}: {error:?}");
}
});
}
}
}