1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14

fn service_proxy() -> Result<(), zmq::Error> {
    let context = zmq::Context::new();
    let frontend = super::create_and_bind_socket(&context, zmq::ROUTER, "tcp://*:10422")?;
    let backend = super::create_and_bind_socket(&context, zmq::ROUTER, "tcp://*:10423")?;

    zmq::poll(
        &mut [
            frontend.as_poll_item(zmq::POLLIN),
            backend.as_poll_item(zmq::POLLIN),
        ],
        3,
    )?;
    Ok(())
}