Remove unnecessary error mapping

Signed-off-by: Tomasz Pietrek <[email protected]>
nats-io · Jan 19, 2024 · af0a135 · af0a135
1 parent de13d17
commit af0a135
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/async-nats/src/jetstream/consumer/pull.rs b/async-nats/src/jetstream/consumer/pull.rs
@@ -2267,7 +2267,6 @@ async fn recreate_consumer_stream(
         stream.delete_consumer(consumer_name),
     )
     .await
-    .map_err(|err| ConsumerRecreateError::with_source(ConsumerRecreateErrorKind::TimedOut, err))
     .ok();
 
     let deliver_policy = {