make consumer info cluster field optional

nats-io · Feb 24, 2023 · 046e595 · 046e595
1 parent 5ad3cf2
commit 046e595
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/async-nats/src/jetstream/consumer/mod.rs b/async-nats/src/jetstream/consumer/mod.rs
@@ -171,7 +171,7 @@ pub struct Info {
     pub num_pending: u64,
     /// Information about the consumer's cluster
     #[serde(default)]
-    pub cluster: ClusterInfo,
+    pub cluster: Option<ClusterInfo>,
     /// Indicates if any client is connected and receiving messages from a push consumer
     #[serde(default)]
     pub push_bound: bool,

diff --git a/async-nats/tests/jetstream_tests.rs b/async-nats/tests/jetstream_tests.rs
@@ -389,7 +389,9 @@ mod jetstream {
             .await
             .unwrap();
 
-        assert_eq!(consumer.cached_info().cluster.replicas.len(), 2);
+        let cluster = consumer.cached_info().cluster.as_ref().unwrap();
+
+        assert_eq!(cluster.replicas.len(), 2);
 
         context.delete_stream("events2").await.unwrap();
     }