make streams optional (#472)

jamsocket · Oct 26, 2023 · 018ada8 · 018ada8
1 parent e3396d2
commit 018ada8
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/core/src/messages/mod.rs b/core/src/messages/mod.rs
@@ -29,10 +29,10 @@ async fn add_jetstream_stream<T: JetStreamable>(
 pub async fn initialize_jetstreams(
     jetstream: &async_nats::jetstream::Context,
 ) -> anyhow::Result<()> {
-    add_jetstream_stream::<state::WorldStateMessage>(jetstream).await?;
-    add_jetstream_stream::<agent::DroneLogMessage>(jetstream).await?;
-    add_jetstream_stream::<agent::BackendStateMessage>(jetstream).await?;
-    add_jetstream_stream::<dns::SetDnsRecord>(jetstream).await?;
+    let _ = add_jetstream_stream::<state::WorldStateMessage>(jetstream).await;
+    let _ = add_jetstream_stream::<agent::DroneLogMessage>(jetstream).await;
+    let _ = add_jetstream_stream::<agent::BackendStateMessage>(jetstream).await;
+    let _ = add_jetstream_stream::<dns::SetDnsRecord>(jetstream).await;
 
     Ok(())
 }