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 ca36bd4 commit ee3119dCopy full SHA for ee3119d
redis/src/aio/connection.rs
@@ -450,6 +450,12 @@ pub(crate) async fn connect_simple<T: RedisRuntime>(
450
) -> RedisResult<(T, Option<IpAddr>)> {
451
Ok(match connection_info.addr {
452
ConnectionAddr::Tcp(ref host, port) => {
453
+ if let Some(socket_addr) = _socket_addr {
454
+ return Ok::<_, RedisError>((
455
+ <T>::connect_tcp(socket_addr).await?,
456
+ Some(socket_addr.ip()),
457
+ ));
458
+ }
459
let socket_addrs = get_socket_addrs(host, port).await?;
460
select_ok(socket_addrs.map(|socket_addr| {
461
info!("IP of node {:?} is {:?}", host, socket_addr.ip());
0 commit comments