Assertion failed: _input_stopped

[jean-airoldie]

See zeromq/libzmq#3596.

Here is a minimal rust test code to reproduce the issue.

use {
    failure::Error,
    libzmq::{prelude::*, *},
    std::{thread, time::Duration},
};

fn main() -> Result<(), Error> {
    let addr: TcpAddr = "0.0.0.0:*".try_into()?;

    let server = ServerBuilder::new().bind(addr).build()?;

    let addr = server.last_endpoint()?.unwrap();

    let client = ClientBuilder::new()
        .connect(addr)
        .recv_hwm(1)
        .heartbeat(Heartbeat::new(Duration::from_secs(1)))
        .build()?;

    // Retreive the routing id of the client.
    client.send("")?;
    let mut msg = server.recv_msg()?;
    let id = msg.routing_id().unwrap();

    thread::spawn(move || loop {
        // Send an empty message to the client using the routing_id.
        server.route("", id).unwrap();
    });

    // Simulate a slow client by receiving a message and waiting 10sec.
    loop {
        client.recv(&mut msg)?;
        thread::sleep(Duration::from_secs(10));
    }
}