@@ -7,7 +7,7 @@ use futures::future::ok;
77
88use ntex:: channel:: mpsc;
99use ntex:: codec:: BytesCodec ;
10- use ntex:: framed:: { Builder , Connect , FactoryBuilder } ;
10+ use ntex:: framed:: { Builder , FactoryBuilder , Handshake } ;
1111use ntex:: rt:: time:: delay_for;
1212use ntex:: server:: test_server;
1313use ntex:: { fn_factory_with_config, fn_service, IntoService , Service } ;
@@ -20,7 +20,7 @@ async fn test_basic() {
2020 let client_item = Rc :: new ( Cell :: new ( false ) ) ;
2121
2222 let srv = test_server ( move || {
23- FactoryBuilder :: new ( fn_service ( |conn : Connect < _ , _ > | async move {
23+ FactoryBuilder :: new ( fn_service ( |conn : Handshake < _ , _ > | async move {
2424 delay_for ( Duration :: from_millis ( 50 ) ) . await ;
2525 Ok ( conn. codec ( BytesCodec ) . state ( State ( None ) ) )
2626 } ) )
@@ -30,7 +30,7 @@ async fn test_basic() {
3030 } ) ;
3131
3232 let item = client_item. clone ( ) ;
33- let client = Builder :: new ( fn_service ( move |conn : Connect < _ , _ > | async move {
33+ let client = Builder :: new ( fn_service ( move |conn : Handshake < _ , _ > | async move {
3434 let ( tx, rx) = mpsc:: channel ( ) ;
3535 let _ = tx. send ( Bytes :: from_static ( b"Hello" ) ) ;
3636 Ok ( conn. codec ( BytesCodec ) . out ( rx) . state ( State ( Some ( tx) ) ) )
0 commit comments