harryisquite.gay / rocksky
forked from rocksky.app/rocksky
A decentralized music tracking and discovery platform built on AT Protocol 🎵
0
fork

Configure Feed

Select the types of activity you want to include in your feed.

Flush NATS connection after publish

Tsiry Sandratraina ae8d6d8e 8cf07b26

+2
+2
crates/jetstream/src/repo.rs
··· 277 277 tracing::info!(server = %addr.bright_green(), "Connected to NATS"); 278 278 279 279 nc.publish("rocksky.user", payload.into()).await?; 280 + nc.flush().await?; 281 + 280 282 Ok::<(), Error>(()) 281 283 }); 282 284