Crate zzrpc 

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

Consumer related functionality.

producer

Producer related functionality.

Structs

DefaultReceiveErrorCallback

Default ReceiveErrorCallback.

DefaultSendErrorCallback

Default SendErrorCallback.

JoinHandle

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

Enums

Error

RPC error.

HandlingStrategy

Send/receive error handling strategy.

ShutdownType

Cause of producer/consumer shutdown.

Timeout

Timeout future.

Traits

ReceiveErrorCallback

Callback called when producer/consumer encounters an error while trying to receive a message from transport.

SendErrorCallback

Callback called when producer encounters an error while trying to send a message through transport.

Functions

spawn

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

Attribute Macros

api

Macro for marking traits defining api’s interface.

Derive Macros

Produce

Derive macro implementing Produce trait for struct.