nextjs-rust-twitter-streaming-websocket-save-trigger-twitter-stream.rs

nextjs-rust-twitter-streaming-websocket-save-trigger-twitter-stream.rs

client.sender = Some(client_sender);
clients.write().await.insert(id.clone(), client);

log::info!("[ws] client_connect : {} connected", id);

let locked = clients.write().await;
if let Some(v) = locked.get(&id) {
  if let Some(sender) = &v.sender {
    log::info!("[ws] client_msg : topic {:?}", v.topic);
    twitter_stream(v.topic.clone(), sender.clone()).await;
  }
}