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

cleanup tests

Browse source
This commit is contained in:
Nikolay Kim 2020-05-16 12:37:27 +06:00
parent 57838b5122
commit ddb3867252
2 changed files with 9 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -569,9 +569,15 @@ mod tests {
use crate::BytesCodec; use crate::BytesCodec;
#[ntex::test] #[ntex::test]
async fn test_debug() { async fn test_basics() {
let (_, server) = Io::create(); let (_, server) = Io::create();
let server = Framed::new(server, BytesCodec); let mut server = Framed::new(server, BytesCodec);
server.get_codec_mut();
server.get_ref();
server.get_mut();
let parts = server.into_parts();
let server = Framed::from_parts(FramedParts::new(parts.io, parts.codec));
assert!(format!("{:?}", server).contains("Framed")); assert!(format!("{:?}", server).contains("Framed"));
} }

2
ntex/src/server/worker.rs
View file

@ -170,7 +170,7 @@ impl Worker {
let (tx2, rx2) = unbounded(); let (tx2, rx2) = unbounded();
let avail = availability.clone(); let avail = availability.clone();
Arbiter::new().exec_fn(move || { Arbiter::default().exec_fn(move || {
let _ = spawn(async move { let _ = spawn(async move {
match Worker::create(rx1, rx2, factories, availability, shutdown_timeout) match Worker::create(rx1, rx2, factories, availability, shutdown_timeout)
.await .await