tokio-zmq 0.10.1

use std::sync::Arc;

use failure::{Error, Fail};
use futures::{future::Future, stream::Stream, sync::mpsc::channel};
use tokio::runtime::current_thread;
use tokio_zmq::{prelude::*, Dealer};

const COUNT: usize = 500;

fn main() {
    std::env::set_var("RUST_LOG", "tokio_zmq=trace");
    env_logger::init();

    let socket = Dealer::builder(Arc::new(zmq::Context::new()))
        .bind("ipc:///tmp/lost-send")
        .build()
        .wait()
        .unwrap();
    let (sink, stream) = socket.sink_stream(COUNT).split();

    let (tx, rx) = channel(COUNT);

    let receive_process = stream.from_err::<Error>().forward(tx);
    let send_process = rx.map_err(|_| RecvError).from_err::<Error>().forward(sink);

    current_thread::Runtime::new()
        .unwrap()
        .spawn(send_process.map(|_| ()).map_err(|_| panic!()))
        .spawn(receive_process.map(|_| ()).map_err(|_| panic!()))
        .run()
        .unwrap();
}

#[derive(Clone, Debug, Fail)]
#[fail(display = "Failed to receive data from mpsc")]
struct RecvError;