diff --git a/src/connection.rs b/src/connection.rs index 1bf409ab..f7bc4721 100644 --- a/src/connection.rs +++ b/src/connection.rs @@ -256,7 +256,7 @@ where }, }; - match broker.metadata_request(&request_params).await { + match broker.metadata_request(request_params).await { Ok(response) => ControlFlow::Break(Ok(response)), Err(e @ RequestError::Poisoned(_) | e @ RequestError::IO(_)) if broker_override.is_none() =>