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?;
        }
    }
}