Skip to main content

JoinQueue

Trait JoinQueue 

Source
pub trait JoinQueue<T: Send + 'static> {
    type Sender: JoinSender<T> + Clone + Send + 'static;
    type Receiver: JoinReceiver<T> + Send + 'static;

    // Required method
    fn split(self) -> (Self::Sender, Self::Receiver);
}
Expand description

A bounded fan-in queue that can be split into a sender/receiver pair.

Required Associated Types§

Source

type Sender: JoinSender<T> + Clone + Send + 'static

Source

type Receiver: JoinReceiver<T> + Send + 'static

Required Methods§

Source

fn split(self) -> (Self::Sender, Self::Receiver)

Implementors§