tokio_udp_recv.rs

extern crate tokio_core;
extern crate futures;

use std::io;
use std::net::{self, SocketAddr, ToSocketAddrs};

use tokio_core::net::{RecvDgram, UdpSocket};
use futures::Future;

fn handle_dgram
    (arg: (UdpSocket, Vec<u8>, usize, net::SocketAddr))
     -> Box<Future<Item = (UdpSocket, Vec<u8>, usize, net::SocketAddr), Error = io::Error>> {

    let (sock, buf, _, _) = arg;

    println!("{:?}", buf);

    Box::new(sock.recv_dgram(buf).and_then(handle_dgram))
}


fn main() {
    let mut l = tokio_core::reactor::Core::new().unwrap();
    let handle = l.handle();
    let addr = "0.0.0.0:12345".to_socket_addrs().unwrap().next().unwrap();
    let sock = UdpSocket::bind(&addr, &handle).unwrap();

    let mut buf = Vec::new();
    buf.resize(128, 0);
    let recv = sock.recv_dgram(buf);

    l.run(recv.and_then(handle_dgram));
}