use crate::user::utils::generate_unique_registered_user_client; use client_api::ws::{ConnectState, WSClient, WSClientConfig}; use wasm_bindgen_test::wasm_bindgen_test; #[wasm_bindgen_test] async fn realtime_connect_test() { let (c, _user) = generate_unique_registered_user_client().await; let ws_client = WSClient::new(WSClientConfig::default(), c.clone(), c.clone()); let mut state = ws_client.subscribe_connect_state(); let device_id = "fake_device_id"; loop { tokio::select! { _ = ws_client.connect(c.ws_url(device_id).await.unwrap(), device_id) => {}, value = state.recv() => { let new_state = value.unwrap(); if new_state == ConnectState::Connected { break; } }, } } }