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

Update tests

Browse source
This commit is contained in:
Nikolay Kim 2024-08-26 19:09:55 +05:00
parent d061a1acf2
commit 487faa3379
2 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
ntex/tests/http_server.rs
View file

@ -122,7 +122,7 @@ async fn test_chunked_payload() {
let returned_size = {
let mut stream = net::TcpStream::connect(srv.addr()).unwrap();
let _ =
stream.write_all(b"POST /test HTTP/1.1\r\nTransfer-Encoding: chunked\r\n\r\n");
stream.write_all(b"POST /test HTTP/1.1\r\nConnection: close\r\nTransfer-Encoding: chunked\r\n\r\n");
for chunk_size in chunk_sizes.iter() {
let mut bytes = Vec::new();
@ -722,7 +722,7 @@ async fn test_h1_client_drop() -> io::Result<()> {
let result = timeout(Millis(100), srv.request(Method::GET, "/").send()).await;
assert!(result.is_err());
sleep(Millis(150)).await;
sleep(Millis(250)).await;
assert_eq!(count.load(Ordering::Relaxed), 1);
Ok(())
}

6
ntex/tests/server.rs
View file

@ -1,6 +1,10 @@
#![allow(clippy::let_underscore_future)]
#[cfg(feature = "tokio")]
use std::sync::atomic::{AtomicUsize, Ordering::Relaxed};
use std::{io, io::Read, net, sync::mpsc, sync::Arc, thread, time};
#[cfg(feature = "tokio")]
use std::{io, sync::Arc};
use std::{io::Read, net, sync::mpsc, thread, time};
use ntex::codec::BytesCodec;
use ntex::io::Io;