We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9b0cebb commit 8c2c83cCopy full SHA for 8c2c83c
sqlx-core/src/net/socket/mod.rs
@@ -234,18 +234,15 @@ pub async fn connect_tcp<Ws: WithSocket>(
234
}
235
236
async fn connect_tcp_address(socket_addr: SocketAddr) -> crate::Result<impl Socket> {
237
- #[cfg(feature = "_rt-tokio")]
238
- if crate::rt::rt_tokio::available() {
239
- use tokio::net::TcpStream;
240
-
241
- let stream = TcpStream::connect(socket_addr).await?;
242
- stream.set_nodelay(true)?;
+ cfg_if! {
+ if #[cfg(feature = "_rt-tokio")] {
+ use tokio::net::TcpStream;
243
244
- return Ok(stream);
245
- }
+ let stream = TcpStream::connect(socket_addr).await?;
+ stream.set_nodelay(true)?;
246
247
- cfg_if! {
248
- if #[cfg(feature = "_rt-async-io")] {
+ Ok(stream)
+ } else if #[cfg(feature = "_rt-async-io")] {
249
use async_io::Async;
250
use std::net::TcpStream;
251
0 commit comments