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,
    },
}

[−] Expand description

A multiplexed protocol frame

Variants

Message

[−] Expand description

Either a request or a response.

[+] Show Fields of Message

Fields of Message

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

[−] Expand description

Body frame.

[+] Show Fields of Body

Fields of Body

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

[−] Expand description

Error

[+] Show Fields of Error

Fields of Error

id: RequestId	Message exchange identifier
error: E	Error value

Methods

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

pub fn request_id(&self) -> RequestId[−]

Return the request ID associated with the frame.

pub fn unwrap_msg(self) -> T[−]

Unwraps a frame, yielding the content of the Message.

pub fn unwrap_body(self) -> Option<B>[−]

Unwraps a frame, yielding the content of the Body.

pub 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.