Set proper return type from consumer info

nats-io · Jun 3, 2022 · 50eefe3 · 50eefe3
1 parent ce36042
commit 50eefe3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/async-nats/src/jetstream/stream.rs b/async-nats/src/jetstream/stream.rs
@@ -117,7 +117,9 @@ impl Stream {
                     error.code, error.description
                 ),
             ))),
-            Response::Ok(info) => Ok(Consumer::new(T::try_from_consumer_config(info)?)),
+            Response::Ok::<ConsumerInfo>(info) => {
+                Ok(Consumer::new(T::try_from_consumer_config(info.config)?))
+            }
         }
     }