diff --git a/core/src/transport/and_then.rs b/core/src/transport/and_then.rs index 6ebb15fe..94b341bf 100644 --- a/core/src/transport/and_then.rs +++ b/core/src/transport/and_then.rs @@ -101,7 +101,7 @@ where let future = dialed_fut // Try to negotiate the protocol. .and_then(move |(connection, client_addr)| { - upgrade(connection, Endpoint::Listener, client_addr) + upgrade(connection, Endpoint::Dialer, client_addr) }); Ok(Box::new(future))