Struct Reply 

pub struct Reply<B> { /* private fields */ }

A reply to a Delivery that was sent onto a RpcBus

Trait Implementations

impl<B: RpcBus> Bus for Reply<B>

type Chan = RpcChannel

The Channel this bus is associated with.

type PublishPayload = <B as RpcBus>::ReplyPayload

The type of payload of the messages that are published on or consumed from it.

fn serialize_payload(payload: &Self::PublishPayload) -> Result<Vec<u8>>

Serialize Bus::PublishPayload into a Vec

fn deserialize_payload(bytes: &[u8]) -> Result<Self::PublishPayload>

Deserialize a byte slice into a Bus::PublishPayload

impl<B: Debug> Debug for Reply<B>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<B: RpcBus> DirectBus for Reply<B>

type Args = <B as DirectBus>::Args

The arguments used to format the queue

fn queue(args: Self::Args) -> String

Method with which queue names are built

impl<B: RpcBus> RpcBus for Reply<B>

type ReplyPayload = <B as Bus>::PublishPayload

The type of payload of the replies of messages published on this bus.

fn serialize_reply(payload: &Self::ReplyPayload) -> Result<Vec<u8>>

Serialize RpcBus::ReplyPayload into a Vec

fn deserialize_reply(bytes: &[u8]) -> Result<Self::ReplyPayload>

Deserialize a byte slice into a RpcBus::ReplyPayload