Enum tokio_proto::streaming::multiplex::Frame

pub enum Frame<T, B, E> {
    Message {
        id: RequestId,
        message: T,
        body: bool,
        solo: bool,
    },
    Body {
        id: RequestId,
        chunk: Option<B>,
    },
    Error {
        id: RequestId,
        error: E,
    },
}

A multiplexed protocol frame

Variants

Message

Either a request or a response.

Fields

id: RequestId	Message exchange identifier
message: T	The message value
body: bool	Set to true when body frames will follow with the same request ID.
solo: bool	Set to true when this message does not have a pair in the other direction

Body

Body frame.

Fields

id: RequestId	Message exchange identifier
chunk: Option<B>	Body chunk. Setting to None indicates that the body is done streaming and there will be no further body frames sent with the given request ID.

Error

Error

Fields

id: RequestId	Message exchange identifier
error: E	Error value

Methods

impl<T, B, E> Frame<T, B, E>

fn request_id(&self) -> RequestId

Return the request ID associated with the frame.

fn unwrap_msg(self) -> T

Unwraps a frame, yielding the content of the Message.

fn unwrap_body(self) -> Option<B>

Unwraps a frame, yielding the content of the Body.

fn unwrap_err(self) -> E

Unwraps a frame, yielding the content of the Error.

Trait Implementations

impl<T: Debug, B: Debug, E: Debug> Debug for Frame<T, B, E>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<T: Clone, B: Clone, E: Clone> Clone for Frame<T, B, E>

fn clone(&self) -> Frame<T, B, E>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.