server/src/routes/streamsync.rs


1
2
3
4
5
6
7
8
9
10
11

use rocket::get;
use rocket_ws::{Stream, WebSocket};

#[get("/streamsync")]
pub fn r_streamsync(ws: WebSocket) -> Stream!['static] {
    Stream! { ws =>
        for await message in ws {
            yield message?;
        }
    }
}