andras/vault-link
andras/vault-link
Watch
1
0
Fork
You've already forked vault-link
 0
Code Issues Pull requests 18 Projects Releases 55 Packages Wiki Activity Actions 35

Fmt

Browse source
This commit is contained in:
Andras Schmelczer 2026-09-19 17:08:10 +01:00
commit cc5ad0f27c
1 changed files with 14 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

6
sync-server/src/server/endpoints/websocket.rs
View file

@ -75,7 +75,7 @@ async fn websocket(
// notifications are only wakeups, so lag and commit/notify crashes are safe.
let result = async {
loop {
let batch = state.database.events_after(&vault, after).await.map_err(|error| server_error(error.into()))?;
let batch = state.database.events_after(&vault, after).await.map_err(server_error)?;
if !batch.events.is_empty() {
let head = batch.head_event_id;
@ -107,12 +107,12 @@ async fn websocket(
}
}
},
Some(Ok(Message::Ping(_))) | Some(Ok(Message::Pong(_))) => {},
Some(Ok(Message::Ping(_) | Message::Pong(_))) => {},
_ => break,
}
}
}
Ok(())
}.await;