We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4ca9f2b commit 3dc1c8bCopy full SHA for 3dc1c8b
src/util/connection_pool.rs
@@ -180,7 +180,7 @@ impl Context {
180
.timeout(context.options.connect_timeout)
181
.await
182
.map_err(|_| PoolConnectError::Timeout)
183
- .and_then(|r| r.map_err(PoolConnectError::from));
+ .and_then(|r| r);
184
let conn_close = match &state {
185
Ok(conn) => {
186
let conn = conn.clone();
@@ -799,7 +799,7 @@ mod tests {
799
let msg = b"Hello, pool!".to_vec();
800
for id in &ids {
801
let res = client.echo(*id, msg.clone()).await;
802
- assert!(matches!(res, Err(PoolConnectError::Timeout { .. })));
+ assert!(matches!(res, Err(PoolConnectError::Timeout)));
803
}
804
shutdown_routers(routers).await;
805
Ok(())
0 commit comments