-// websocat ws://127.0.0.1:3030/ws-rev
-async fn ws_rev_connected(websocket: warp::ws::WebSocket) {
- // echo all messages back
- tokio::task::spawn(async {
- let (mut tx, mut rx) = websocket.split();
- while let Some(message) = rx.next().await {
- let msg = match message {
- Ok(msg) => msg,
- Err(e) => {
- log::error!("websocket error: {}", e);
- break;
- }
- };
- log::info!("ws_rev_connected: got message: {:?}", msg);
+ // websocat ws://127.0.0.1:3030/ws-rev
+ pub async fn ws_rev_connected(websocket: warp::ws::WebSocket) {
+ // echo all messages back
+ tokio::task::spawn(async {
+ let (mut tx, mut rx) = websocket.split();
+ while let Some(message) = rx.next().await {
+ let msg = match message {
+ Ok(msg) => msg,
+ Err(e) => {
+ log::error!("websocket error: {}", e);
+ break;
+ }
+ };
+ log::info!("ws_rev_connected: got message: {:?}", msg);