mirror of
https://github.com/chatmail/core.git
synced 2026-05-03 13:26:28 +03:00
fix compile after rebase
This commit is contained in:
@@ -34,8 +34,8 @@ async fn request_handler(
|
|||||||
}
|
}
|
||||||
|
|
||||||
async fn event_loop(state: CommandApi, rpc: RpcHandle) -> anyhow::Result<()> {
|
async fn event_loop(state: CommandApi, rpc: RpcHandle) -> anyhow::Result<()> {
|
||||||
let mut events = state.accounts.read().await.get_event_emitter().await;
|
let events = state.accounts.read().await.get_event_emitter().await;
|
||||||
while let Ok(Some(event)) = events.recv().await {
|
while let Some(event) = events.recv().await {
|
||||||
// log::debug!("event {:?}", event);
|
// log::debug!("event {:?}", event);
|
||||||
let event = event_to_json_rpc_notification(event);
|
let event = event_to_json_rpc_notification(event);
|
||||||
rpc.notify("event", Some(event)).await?;
|
rpc.notify("event", Some(event)).await?;
|
||||||
|
|||||||
Reference in New Issue
Block a user