libzmq-rs
libzmq-rs copied to clipboard
A strict subset of ØMQ with an ergonomic API.
All attempts to bind to an address are creating an IPv6 socket instead of the desired IPv4 socket. For example: ``` let addr: TcpAddr = "0.0.0.0:1234".try_into().unwrap(); let server = ServerBuilder::new().bind(&addr).build().unwrap();...
This fixes #127.
Blocked until [async await stabilization](https://github.com/rust-lang/rust/issues/50547).
**Describe the bug** A clear and concise description of what the bug is. `libzmq` does not ensure all messages are sent before socket is dropped. **To Reproduce** Give a minimal...
**Describe the bug** The library does not build under Windows. error[E0432]: unresolved import `windows` --> %userprofile%\.cargo\registry\src\github.com-1ecc6299db9ec823\libzmq-sys-0.1.7+4.3.2\src\errno.rs:6:5 | 6 | use windows::errno; | ^^^^^^^ use of undeclared type or module `windows`...
When a connection succeeds the socket is no longer in mute state and can queue outgoing messages via `send`. The problem is if the authentication failed the user will never...
By leveraging the `zmq_socket_monitor` API, allow sockets to receive events that are normally discarted by `libzmq`. Allow the user to configure what events should be received or discarded. See #122...
See https://github.com/zeromq/libzmq/issues/3596. Here is a minimal rust test code to reproduce the issue. ```rust use { failure::Error, libzmq::{prelude::*, *}, std::{thread, time::Duration}, }; fn main() -> Result { let addr: TcpAddr...
Allow retrieval of the "Peer-Address" metadata, as defined in http://api.zeromq.org/master:zmq-msg-gets.
We should provide for some channel patterns that can send `Box` allocated arbitrary types for inter thread communication.