mirror of
				https://github.com/async-rs/async-std.git
				synced 2025-10-31 16:56:38 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			36 lines
		
	
	
	
		
			793 B
		
	
	
	
		
			Rust
		
	
	
	
	
	
			
		
		
	
	
			36 lines
		
	
	
	
		
			793 B
		
	
	
	
		
			Rust
		
	
	
	
	
	
| //! UDP client.
 | |
| //!
 | |
| //! First start the echo server:
 | |
| //!
 | |
| //! ```sh
 | |
| //! $ cargo run --example udp-echo
 | |
| //! ```
 | |
| //!
 | |
| //! Then run the client:
 | |
| //!
 | |
| //! ```sh
 | |
| //! $ cargo run --example udp-client
 | |
| //! ```
 | |
| 
 | |
| #![feature(async_await)]
 | |
| 
 | |
| use async_std::io;
 | |
| use async_std::net::UdpSocket;
 | |
| use async_std::task;
 | |
| 
 | |
| fn main() -> io::Result<()> {
 | |
|     task::block_on(async {
 | |
|         let socket = UdpSocket::bind("127.0.0.1:8081").await?;
 | |
|         println!("Listening on {}", socket.local_addr()?);
 | |
| 
 | |
|         let msg = "hello world";
 | |
|         println!("<- {}", msg);
 | |
|         socket.send_to(msg.as_bytes(), "127.0.0.1:8080").await?;
 | |
| 
 | |
|         let mut buf = vec![0u8; 1024];
 | |
|         let (n, _) = socket.recv_from(&mut buf).await?;
 | |
|         println!("-> {}\n", String::from_utf8_lossy(&buf[..n]));
 | |
| 
 | |
|         Ok(())
 | |
|     })
 | |
| }
 |