static STREAM: Lazy>>>> = Lazy::new(|| {
let url: &str = &URL;
let token: &str = &TOKEN;
let stream_url = format!("wss://{}/streaming?i={}", url, token);
let (stream, _) = tokio::runtime::Runtime::new().unwrap().block_on(async {
connect_async(stream_url)
.await
.expect("Failed to connect")
});
Arc::new(Mutex::new(stream))
});
