Searched refs:shutdown (Results 1 – 8 of 8) sorted by relevance
123 s.shutdown(Shutdown::Write).await?; in test_stream()141 s.shutdown(Shutdown::Read).await?; in test_stream()191 poll_stream.shutdown().await?; in test_poll_stream()
368 self.shutdown(Shutdown::Both).await in close()377 pub async fn shutdown(&self, how: Shutdown) -> Result<()> { in shutdown() method816 stream.shutdown(Shutdown::Write).await in poll_shutdown()
103 stream.shutdown(Shutdown::Both).await?; in main()
112 stream.shutdown(Shutdown::Both).await?; in main()
318 Ok(self.stream.shutdown(Shutdown::Both).await?) in close()642 .shutdown(Shutdown::Write) in poll_shutdown()
1836 s0.shutdown(Shutdown::Both).await?; // send reset in test_assoc_reset_close_one_way()1935 s0.shutdown(Shutdown::Both).await?; // send reset in test_assoc_reset_close_both_ways()1989 s1.shutdown(Shutdown::Both).await?; // send reset in test_assoc_reset_close_both_ways()2332 if let Ok(result) = tokio::time::timeout(Duration::from_secs(1), a1.shutdown()).await { in test_association_shutdown()2413 res = tokio::time::timeout(Duration::from_secs(1), a1.shutdown()) => { in test_association_shutdown_during_write()
249 pub async fn shutdown(&self) -> Result<()> { in shutdown() method
518 let shutdown = ChunkShutdown { in gather_outbound_shutdown_packets() localVariable522 let p = self.create_packet(vec![Box::new(shutdown)]); in gather_outbound_shutdown_packets()