Enum tokio_proto::streaming::pipeline::Frame

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

A pipelined protocol frame

Variants

Message

Either a request or a response

Fields of Message

message: T	The message value
body: bool	Set to true when body frames will follow

Body

Body frame. None indicates that the body is done streaming.

Fields of Body

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 of Error

error: E

Error value

Methods

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

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.