Crate zzrpc

Expand description

RPC over mezzenger transports.

Go to repository to see code examples and tutorial explaining how to use it.

Re-exports

pub use atomic_counter;

pub use futures;

pub use crate::consumer::Consume;

Consumer related functionality.

Producer related functionality.

An owned permission to join on a task (await its termination).

Future returned by consumer streaming requests.

Future returned by consumer value requests.

RPC error.

Send/receive error handling strategy.

Cause of producer/consumer shutdown.

Timeout future.

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.

Spawns a new asynchronous task, returning a JoinHandle for it.

Macro for marking traits defining api’s interface.

Derive macro implementing Produce trait for struct.