1use anyhow::Error; 2 3pub async fn start_jetstream_service() -> Result<(), Error> { 4 rocksky_jetstream::subscribe().await?; 5 Ok(()) 6}