Struct queen::stream::Stream

pub struct Stream<T: Send> {
    pub tx: StreamTx<T>,
    pub rx: StreamRx<T>,
}

Fields

tx: StreamTx<T>

rx: StreamRx<T>

Methods

impl<T: Send> Stream<T>

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

pub fn split(self) -> (StreamTx<T>, StreamRx<T>)

pub fn attr(&self) -> &Message

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

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

pub fn close(&self)

pub fn is_close(&self) -> bool

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

Trait Implementations

impl<T: Send> Evented for Stream<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<()>