omq

Facade crate for omq. Re-exports one backend:

Mutually exclusive.

Install

cargo add omq                     # compio backend (default)
cargo add omq --no-default-features --features tokio-backend

Usage

use omq::Socket;
use omq::prelude::*;

let push = Socket::new(SocketType::Push, Options::default());
push.bind("tcp://127.0.0.1:5555".parse()?).await?;

let pull = Socket::new(SocketType::Pull, Options::default());
pull.connect("tcp://127.0.0.1:5555".parse()?).await?;

push.send(Message::single("hello")).await?;
let msg = pull.recv().await?;

See the workspace README for benchmarks, feature matrix, and interop details.

License

ISC