17     setup(family, |mut server, mut client| async move {  in test_tcp_ping_pong()
23             let (status, buf) = client.receive_stream.read(Vec::with_capacity(4)).await;  in test_tcp_ping_pong()
28             let rest = client.send_stream.write_all(b"pong".into()).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()
47         let (stream_result, data) = client.receive_stream.read(Vec::with_capacity(1)).await;  in test_tcp_receive_stream_should_be_dropped_by_remote_shutdown()
50         client.receive_result.await.unwrap();  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()
64             let Connection { mut receive_stream, receive_result, .. } = client;  in test_tcp_receive_future_should_resolve_when_stream_dropped()
79     setup(family, |_server, client| async move {  in test_tcp_send_future_should_resolve_when_stream_dropped()
84         } = client;  in test_tcp_send_future_should_resolve_when_stream_dropped()
93     setup(family, |server, mut client| async move {  in test_tcp_send_drops_stream_when_remote_shutdown()
98             let stream_result = client.send_stream.write(b"undeliverable".into()).await.0;  in test_tcp_send_drops_stream_when_remote_shutdown()
104         let result = client.send_result.await;  in test_tcp_send_drops_stream_when_remote_shutdown()
118     setup(family, |mut server, client| async move {  in test_tcp_receive_once()
128             let (mut reader, future) = client.socket.receive();  in test_tcp_receive_once()
141     setup(family, |_server, client| async move {  in test_tcp_send_once()
146             let future = client.socket.send(send_rx);  in test_tcp_send_once()
161     setup(family, |server, client| async move {  in test_tcp_stream_lifetimes()
175         } = client;  in test_tcp_stream_lifetimes()
219     setup(family, |mut server, mut client| async move {  in test_tcp_read_cancellation()
221         client.socket.set_send_buffer_size(1024).unwrap();  in test_tcp_read_cancellation()
226                     let ret = client.send_stream.write_all(data.to_vec()).await;  in test_tcp_read_cancellation()
229                 drop(client.send_stream);  in test_tcp_read_cancellation()