teal.fm
this repo has no description
switch jetstream url
mmatt.net
+5
-2
+1
-1
Cargo.toml
+1
-1
Cargo.toml
+4
-1
src/main.rs
+4
-1
src/main.rs
···
5
5
connection::JetstreamConnection, handler, ingestion::LexiconIngestor,
6
6
options::JetstreamOptions, types::event::Event,
7
7
};
8
-
use serde_json::{Value, json};
8
+
use serde_json::{json, Value};
9
9
use std::{
10
10
collections::HashMap,
11
11
sync::{Arc, Mutex},
···
20
20
let opts = JetstreamOptions::builder()
21
21
// your EXACT nsids
22
22
.wanted_collections(vec!["fm.teal.alpha.feed.play".to_string()])
23
+
.ws_url(rocketman::endpoints::JetstreamEndpoints::Custom(
24
+
"wss://jetstream1.us-east.fire.hose.cam/subscribe".to_string(),
25
+
))
23
26
.build();
24
27
// create the jetstream connector
25
28
let jetstream = JetstreamConnection::new(opts);