edg-l/teeobserver
1
0
Fork 0
mirror of https://github.com/edg-l/teeobserver.git synced 2024-10-18 14:58:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

x

Browse source
This commit is contained in:
Edgar 2023-10-02 18:25:41 +02:00
parent 09375e6175
commit f3c1cf33c7
No known key found for this signature in database
GPG key ID: 70ADAE8F35904387
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/routes.rs
View file

@ -31,7 +31,10 @@ pub async fn ws_handler(
let rx = state.events_sender.subscribe(); let rx = state.events_sender.subscribe();
// finalize the upgrade process by returning upgrade callback. // finalize the upgrade process by returning upgrade callback.
// we can customize the callback by sending additional info such as address. // we can customize the callback by sending additional info such as address.
ws.on_upgrade(move |socket| handle_socket(socket, addr, rx)) ws.on_failed_upgrade(|error| {
error!("error upgrading connection: {error}");
})
.on_upgrade(move |socket| handle_socket(socket, addr, rx))
} }
/// Actual websocket statemachine (one will be spawned per connection) /// Actual websocket statemachine (one will be spawned per connection)