Struct queen::wire::Wire

pub struct Wire<T: Send> { /* fields omitted */ }

Implementations

impl<T: Send> Wire<T>

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

pub fn capacity(&self) -> usize

pub fn attr(&self) -> LockGuard<Message>

pub fn close(&self)

pub fn is_close(&self) -> bool

pub fn is_full(&self) -> bool

pub fn pending(&self) -> usize

pub fn send(&self, data: T) -> Result<(), SendError<T>>

pub fn send_num(&self) -> usize

pub fn recv(&self) -> Result<T, RecvError>

pub fn recv_num(&self) -> usize

pub fn wait(&self, timeout: Option<Duration>) -> Result<T, RecvError>

Trait Implementations

impl<T: Send> Debug for Wire<T>

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

Formats the value using the given formatter.

impl<T: Send> Drop for Wire<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T: Send> Send for Wire<T>

impl<T: Send> Source for Wire<T>

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<()>