zmq.rs
zmq.rs copied to clipboard
zeromq
A native implementation of ØMQ in Rust
In order to support/use ZeroMQ from Zed (for Jupyter notebooks and related interactive computing environments), I need to have zmq.rs support `smol` as the runtime. Posting to starting drafting this.
It took me some time to debug. recv() is not cancel-safe because of `self.current_request.take()`. I have to spawn a tokio task just for ZMQ, if I want to use tokio::select...
In the current implementation, when a SUB provider is restarted, the library just hangs without detecting connection loss. This happens because on disconnect a client is kicked out of the...
One of the reasons for our interest in ZeroMQ is its support of UDP (and multicast, but that's secondary). It would be great if `zmq.rs` could include UDP support. Thank...
I'm on windows,which I suspect is part of this issue. As soon as I add zeromq to my Cargo.toml file,I get this error. `unresolved imports `tokio::net::UnixListener`, `tokio::net::UnixStream` no `UnixListener` in...
Implement PAIR. Fixes #41. I haven't yet fully tested this code but am opening the PR early so I can get feedback.
Sometimes I don't want to be limited by the async-await syntax and would rather just interact with the sockets in Rust inside of my own concurrency code. Could this be...
Initial prototype is working for GenericSocketBackend TODO: * implement for rest of the sockets * implement outgoing queue for messages according to ZMQ spec Related to #143
