Expand description
RPC over mezzenger transports.
Go to repository to see code examples and tutorial explaining how to use it.
Re-exports
pub use crate::consumer::Consume;
pub use crate::consumer::StreamRequest;
pub use crate::consumer::ValueRequest;
pub use atomic_counter;
pub use futures;
Modules
- Consumer related functionality.
- Producer related functionality.
Structs
- Default ReceiveErrorCallback.
- Default SendErrorCallback.
- An owned permission to join on a task (await its termination).
Enums
- RPC error.
- Send/receive error handling strategy.
- Cause of producer/consumer shutdown.
- Timeout future.
Traits
- Callback called when producer/consumer encounters an error while trying to receive a message from transport.
- Callback called when producer encounters an error while trying to send a message through transport.
Functions
- Spawns a new asynchronous task, returning a
JoinHandle
for it.
Attribute Macros
- Macro for marking traits defining api’s interface.
Derive Macros
- Derive macro implementing Produce trait for struct.