mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-03 04:47:39 +03:00
Code Issues Projects Releases Packages Wiki Activity

Make TestServer::connect() async

Browse source
This commit is contained in:
Nikolay Kim 2021-02-24 04:50:49 +06:00
parent 8b059754a6
commit 8bd63b07b3
3 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

1
ntex-codec/src/framed.rs
View file

@ -260,6 +260,7 @@ where
}
}
}
log::trace!("flushed {} bytes", written);
// remove written data
if written == len {

4
ntex/CHANGES.md
View file

@ -1,5 +1,9 @@
# Changes
## [0.3.0-b.2] - 2021-02-24
* server: Make TestServer::connect() async
## [0.3.0-b.1] - 2021-02-24
* Migrate to tokio 1.x

7
ntex/src/server/test.rs
View file

@ -1,6 +1,5 @@
//! Test server
use std::sync::mpsc;
use std::{io, net, thread};
use std::{io, net, sync::mpsc, thread};
use socket2::{Domain, SockAddr, Socket, Type};
@ -107,8 +106,8 @@ impl TestServer {
}
/// Connect to server, return TcpStream
pub fn connect(&self) -> std::io::Result<TcpStream> {
TcpStream::from_std(net::TcpStream::connect(self.addr)?)
pub async fn connect(&self) -> io::Result<TcpStream> {
TcpStream::connect(self.addr).await
}
/// Stop http server