]> git.feebdaed.xyz Git - 0xmirror/tokio.git/commitdiff
stream: improve the the docs of `TcpListenerStream` (#7578)
authorMartin Grigorov <martin-g@users.noreply.github.com>
Sat, 6 Sep 2025 05:36:41 +0000 (08:36 +0300)
committerGitHub <noreply@github.com>
Sat, 6 Sep 2025 05:36:41 +0000 (13:36 +0800)
Signed-off-by: Martin Tzvetanov Grigorov <mgrigorov@apache.org>
tokio-stream/src/wrappers/tcp_listener.rs

index c463ef1426c57b36835dc5c4be149eff4bc0b6c7..feb6405bc062a5a46a8808d7a68fbf859db140da 100644 (file)
@@ -18,12 +18,12 @@ use tokio::net::{TcpListener, TcpStream};
 ///
 /// # #[tokio::main(flavor = "current_thread")]
 /// # async fn main() -> std::io::Result<()> {
-/// let ipv4_listener = TcpListener::bind((Ipv6Addr::LOCALHOST, 8080)).await?;
-/// let ipv6_listener = TcpListener::bind((Ipv4Addr::LOCALHOST, 8080)).await?;
+/// let ipv4_listener = TcpListener::bind((Ipv4Addr::LOCALHOST, 8080)).await?;
+/// let ipv6_listener = TcpListener::bind((Ipv6Addr::LOCALHOST, 8080)).await?;
 /// let ipv4_connections = TcpListenerStream::new(ipv4_listener);
 /// let ipv6_connections = TcpListenerStream::new(ipv6_listener);
 ///
-/// let mut connections = ipv4_connections.chain(ipv6_connections);
+/// let mut connections = ipv4_connections.merge(ipv6_connections);
 /// while let Some(tcp_stream) = connections.next().await {
 ///     let stream = tcp_stream?;
 ///     let peer_addr = stream.peer_addr()?;