17     setup(family, |mut server, mut client| async move {  in test_tcp_ping_pong()
19             let rest = server.send_stream.write_all(b"ping".into()).await;  in test_tcp_ping_pong()
32             let (status, buf) = server.receive_stream.read(Vec::with_capacity(4)).await;  in test_tcp_ping_pong()
43     setup(family, |server, mut client| async move {  in test_tcp_receive_stream_should_be_dropped_by_remote_shutdown()
44         drop(server);  in test_tcp_receive_stream_should_be_dropped_by_remote_shutdown()
58     setup(family, |mut server, client| async move {  in test_tcp_receive_future_should_resolve_when_stream_dropped()
60 …let rest = server.send_stream.write_all(b"Lorem ipsum dolor sit amet, consectetur adipiscing elit,…  in test_tcp_receive_future_should_resolve_when_stream_dropped()
93     setup(family, |server, mut client| async move {  in test_tcp_send_drops_stream_when_remote_shutdown()
94         drop(server);  in test_tcp_send_drops_stream_when_remote_shutdown()
118     setup(family, |mut server, client| async move {  in test_tcp_receive_once()
121 …let rest = server.send_stream.write_all(b"Lorem ipsum dolor sit amet, consectetur adipiscing elit,…  in test_tcp_receive_once()
161     setup(family, |server, client| async move {  in test_tcp_stream_lifetimes()
168         } = server;  in test_tcp_stream_lifetimes()
219     setup(family, |mut server, mut client| async move {  in test_tcp_read_cancellation()
238                         let mut fut = pin!(server.receive_stream.read(buf));  in test_tcp_read_cancellation()
260                             server.receive_stream.read(Vec::new()).await;  in test_tcp_read_cancellation()
265                 server.receive_result.await.unwrap();  in test_tcp_read_cancellation()