From 50eefe322aef15cae8682c6d8a8d181a82eaf7af Mon Sep 17 00:00:00 2001 From: Tomasz Pietrek Date: Fri, 3 Jun 2022 13:00:00 +0200 Subject: [PATCH] Set proper return type from consumer info --- async-nats/src/jetstream/stream.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/async-nats/src/jetstream/stream.rs b/async-nats/src/jetstream/stream.rs index 1e71617a1..2601f7d8d 100644 --- 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::(info) => { + Ok(Consumer::new(T::try_from_consumer_config(info.config)?)) + } } }