Skip to content

Commit

Permalink
fix deprecation warning
Browse files Browse the repository at this point in the history
  • Loading branch information
fafhrd91 committed Jun 12, 2020
1 parent 85fe6d3 commit f3ab3a7
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions ntex/tests/framed_server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ use futures::future::ok;

use ntex::channel::mpsc;
use ntex::codec::BytesCodec;
use ntex::framed::{Builder, Connect, FactoryBuilder};
use ntex::framed::{Builder, FactoryBuilder, Handshake};
use ntex::rt::time::delay_for;
use ntex::server::test_server;
use ntex::{fn_factory_with_config, fn_service, IntoService, Service};
Expand All @@ -20,7 +20,7 @@ async fn test_basic() {
let client_item = Rc::new(Cell::new(false));

let srv = test_server(move || {
FactoryBuilder::new(fn_service(|conn: Connect<_, _>| async move {
FactoryBuilder::new(fn_service(|conn: Handshake<_, _>| async move {
delay_for(Duration::from_millis(50)).await;
Ok(conn.codec(BytesCodec).state(State(None)))
}))
Expand All @@ -30,7 +30,7 @@ async fn test_basic() {
});

let item = client_item.clone();
let client = Builder::new(fn_service(move |conn: Connect<_, _>| async move {
let client = Builder::new(fn_service(move |conn: Handshake<_, _>| async move {
let (tx, rx) = mpsc::channel();
let _ = tx.send(Bytes::from_static(b"Hello"));
Ok(conn.codec(BytesCodec).out(rx).state(State(Some(tx))))
Expand Down

0 comments on commit f3ab3a7

Please sign in to comment.