Skip to main content

ruststream_zeromq/
lib.rs

1#![doc = include_str!("README.md")]
2#![forbid(unsafe_code)]
3
4#[cfg(feature = "asyncapi")]
5mod bindings;
6mod common;
7mod endpoint;
8mod error;
9#[cfg(feature = "testing")]
10mod in_process;
11mod message;
12pub mod prelude;
13mod wire;
14
15// Public, not just re-export sources: each form carries its own prelude.
16pub mod fanout;
17pub mod queue;
18pub mod rpc;
19
20pub use endpoint::{Bind, Connect, EndpointRole, ZmqEndpoint};
21pub use error::ZmqError;
22pub use fanout::{ConnectedZmqFanout, ZmqFanout, ZmqFanoutPublish, ZmqFanoutPublisher};
23pub use message::ZmqMessage;
24pub use queue::{ConnectedZmqQueue, ZmqQueue, ZmqQueuePublish, ZmqQueuePublisher, ZmqSubscriber};
25pub use rpc::{ConnectedZmqRpc, ZmqRpc, ZmqRpcPublish, ZmqRpcPublisher, ZmqRpcSubscriber};