oppi.li
mount jetstream as a userspace character device on linux
excuse: use hose.cam instead
Signed-off-by: oppiliappan <me@oppi.li>
+2
-1
src/main.rs
+2
-1
src/main.rs
···
9
9
use tokio_tungstenite::{connect_async, tungstenite::Message};
10
10
11
11
const DEV: &str = "jetstream";
12
+
const URL: &str = "wss://jetstream1.us-east.fire.hose.cam/subscribe";
12
13
13
14
struct CuseDevice {
14
15
buffer: Arc<Mutex<VecDeque<u8>>>,
···
59
60
) {
60
61
loop {
61
62
info!("connecting to jetstream...");
62
-
match connect_async("wss://jetstream1.us-west.bsky.network/subscribe").await {
63
+
match connect_async(URL).await {
63
64
Ok((mut ws, _)) => {
64
65
info!("connected to jetstream ... ");
65
66