Struct queen::stream::Stream

pub struct Stream {
    pub capacity: usize,
    pub attr: Message,
    // some fields omitted
}

Fields

capacity: usize

attr: Message

Methods

impl Stream

pub fn pipe(capacity: usize, attr: Message) -> Result<(Stream, Stream)>

pub fn send(&self, message: Message)

pub fn recv(&self) -> Option<Message>

pub fn close(&self)

pub fn is_close(&self) -> bool

pub fn is_full(&self) -> bool

Trait Implementations

impl Drop for Stream

fn drop(&mut self)

Executes the destructor for this type.

impl Evented for Stream

fn add(
    &self,
    epoll: &Epoll,
    token: Token,
    interest: Ready,
    opts: EpollOpt
) -> Result<()>

fn modify(
    &self,
    epoll: &Epoll,
    token: Token,
    interest: Ready,
    opts: EpollOpt
) -> Result<()>

fn delete(&self, epoll: &Epoll) -> Result<()>