Struct Resp

pub struct Resp<M: Message> { /* private fields */ }

The Resp represents a full response from a RPC that may have an attached stream.

Implementations

impl<M: Message> Resp<M>

pub fn new(v: M::Response) -> Self

Creates a new response from a base response message

pub fn with_stream_from_buffer(self, b: Bytes) -> Self

Attach a stream to message in response, where the stream is streamed from a fixed Bytes buffer

pub fn with_stream(self, b: ByteStream) -> Self

Attach a stream to message in response, where the stream is an instance of ByteStream.

pub fn with_order_tag(self, order_tag: OrderTag) -> Self

Add an order tag to this response to indicate in which order it should be sent.

pub fn msg(&self) -> &M::Response

Get a reference to the response message contained in this request

pub fn into_msg(self) -> M::Response

Transforms the Resp<M> into the response message it contains, dropping everything else (including attached data stream)

pub fn into_parts(self) -> (M::Response, Option<ByteStream>)

Transforms the Resp<M> into, on the one side, the response message it contains, and on the other side, the associated data stream if it exists

Trait Implementations

impl<M> Debug for Resp<M>

where M: Message, <M as Message>::Response: Debug,

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

Formats the value using the given formatter.