11     setup(net, family, |server, client| {  in test_tcp_input_stream_should_be_closed_by_remote_shutdown()
17         client.input.subscribe().block();  in test_tcp_input_stream_should_be_closed_by_remote_shutdown()
22         assert!(matches!(client.input.read(10), Err(StreamError::Closed)));  in test_tcp_input_stream_should_be_closed_by_remote_shutdown()
25         assert!(matches!(client.input.read(0), Err(StreamError::Closed)));  in test_tcp_input_stream_should_be_closed_by_remote_shutdown()
34     setup(net, family, |server, client| {  in test_tcp_input_stream_should_be_closed_by_local_shutdown()
41         client.input.subscribe().block();  in test_tcp_input_stream_should_be_closed_by_local_shutdown()
44         client.socket.shutdown(ShutdownType::Receive).unwrap();  in test_tcp_input_stream_should_be_closed_by_local_shutdown()
47         assert!(matches!(client.input.read(10), Err(StreamError::Closed)));  in test_tcp_input_stream_should_be_closed_by_local_shutdown()
50         assert!(matches!(client.input.read(0), Err(StreamError::Closed)));  in test_tcp_input_stream_should_be_closed_by_local_shutdown()
59     setup(net, family, |_server, client| {  in test_tcp_output_stream_should_be_closed_by_local_shutdown()
63         assert!(client.output.check_write().unwrap() as usize >= message.len());  in test_tcp_output_stream_should_be_closed_by_local_shutdown()
66         client.socket.shutdown(ShutdownType::Send).unwrap();  in test_tcp_output_stream_should_be_closed_by_local_shutdown()
70             client.output.write(message),  in test_tcp_output_stream_should_be_closed_by_local_shutdown()
76             client.output.check_write(),  in test_tcp_output_stream_should_be_closed_by_local_shutdown()
79         assert!(matches!(client.output.flush(), Err(StreamError::Closed)));  in test_tcp_output_stream_should_be_closed_by_local_shutdown()
85     setup(net, family, |server, client| {  in test_tcp_shutdown_should_not_lose_data()
87         client.socket.set_send_buffer_size(1024).unwrap();  in test_tcp_shutdown_should_not_lose_data()
88         let small_buffer_size = client.socket.send_buffer_size().unwrap();  in test_tcp_shutdown_should_not_lose_data()
91         let big_buffer_size = client  in test_tcp_shutdown_should_not_lose_data()
100         client.output.write(&outgoing_data).unwrap();  in test_tcp_shutdown_should_not_lose_data()
101         client.socket.shutdown(ShutdownType::Send).unwrap();  in test_tcp_shutdown_should_not_lose_data()