Enum tokio_proto::streaming::pipeline::Frame

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

[−] Expand description

A pipelined protocol frame

Variants

Message

[−] Expand description

Either a request or a response

[+] Show Fields of Message

Fields of Message

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

Body

[−] Expand description

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

[+] Show Fields of Body

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

[−] Expand description

Error

[+] Show Fields of 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.