nextjs-rust-twitter-streaming-websocket-split.rs

nextjs-rust-twitter-streaming-websocket-split.rs

let (client_ws_sender, mut _client_ws_rcv) = ws.split();
let (client_sender, client_rcv) = mpsc::unbounded_channel();

let client_rcv = UnboundedReceiverStream::new(client_rcv);  

tokio::task::spawn(client_rcv.forward(client_ws_sender).map(|result| {
  if let Err(e) = result {
    log::error!("Failed toerror sending websocket msg: {}", e);
  }
}));