Struct smartpool::channel::MultiChannel

pub struct MultiChannel<Inner: Channel> { /* fields omitted */ }

A round-robin multi channel wrapper.

Methods

impl<Inner: Channel> MultiChannel<Inner>

pub fn from_vec(inner: Vec<Inner>) -> Self

pub fn new(
    count: usize,
    factory: impl Fn() -> Inner
) -> Self

Trait Implementations

impl<Inner: Channel> Channel for MultiChannel<Inner>

fn assign_bits(
    &mut self,
    assigner: &mut BitAssigner
) -> Result<(), NotEnoughBits>

fn poll(&self) -> Option<RunningTask>

fn into_shared(self) -> Arc<RwLock<Self>> where
    Self: Sized, 

Wrap self in a reference counted read/write lock, which is still a channel, and can have shared ownership, allowing it to be used in a scheduler.

impl<Inner: Channel + Exec> Exec for MultiChannel<Inner>

fn submit(&self, task: RunningTask)

Submit a raw running task.

fn exec(
    &self,
    future: impl Future<Item = (), Error = ()> + Send + 'static
)

Execute a future on this channel.

fn exec_push<I: Send + 'static, E: Send + 'static>(
    &self,
    future: impl Future<Item = I, Error = E> + Send + 'static
) -> PushFutureRecv<I, E>

Execute a future on this channel, and push the result to a push future.

impl<Inner: Channel + ExecParam> ExecParam for MultiChannel<Inner>

type Param = Inner::Param

fn submit(&self, task: RunningTask, param: Self::Param)

Submit a raw running task.

fn exec(
    &self,
    future: impl Future<Item = (), Error = ()> + Send + 'static,
    param: Self::Param
)

Execute a future on this channel.

fn exec_push<I: Send + 'static, E: Send + 'static>(
    &self,
    future: impl Future<Item = I, Error = E> + Send + 'static,
    param: Self::Param
) -> PushFutureRecv<I, E>

Execute a future on this channel, and push the result to a push future.