Last active
November 19, 2015 23:19
-
-
Save stevenpack/bae97c67c3dd5e954428 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| fn accept_udp_connection(mio_server: &MioServer) { | |
| println!("the server socket is ready to accept a UDP connection"); | |
| let mut buf = Vec::<u8>::new(); | |
| let mut mut_slice_buf = MutSliceBuf::wrap(&mut buf); | |
| match mio_server.udp_server.recv_from(&mut mut_slice_buf) { | |
| Ok(Some(addr)) => { | |
| println!("remaining is {}", mut_slice_buf.remaining()); | |
| match String::from_utf8(buf) { | |
| Ok(str) => { | |
| println!("buffer is {}", str); | |
| }, | |
| Err(e) => { | |
| println!("could't convert the buffer to utf8. {}", e); | |
| } | |
| } | |
| let quote = "What udp bytes do you seek avatar?"; | |
| let mut quote_buf = SliceBuf::wrap(&mut quote.as_bytes()); | |
| let _ = mio_server.udp_server.send_to(&mut quote_buf, &addr); | |
| //re-register | |
| } | |
| Ok(None) => println!("The udp socket wasn't actually ready"), | |
| Err(e) => println!("couldn't receive a datagram: {}", e) | |
| } | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment