[−][src]Trait smartpool::channel::Exec
Trait for channels for which a task can be submitted.
Required methods
fn submit(&self, task: RunningTask)
Submit a raw running task.
Provided methods
fn exec(
&self,
future: impl Future<Item = (), Error = ()> + Send + 'static
)
&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>
&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.
Implementations on Foreign Types
impl<E: Exec> Exec for Arc<RwLock<E>>
[src]
Shared exec implementation.
fn submit(&self, task: RunningTask)
[src]
fn exec(
&self,
future: impl Future<Item = (), Error = ()> + Send + 'static
)
[src]
&self,
future: impl Future<Item = (), Error = ()> + Send + 'static
)
fn exec_push<I: Send + 'static, E: Send + 'static>(
&self,
future: impl Future<Item = I, Error = E> + Send + 'static
) -> PushFutureRecv<I, E>
[src]
&self,
future: impl Future<Item = I, Error = E> + Send + 'static
) -> PushFutureRecv<I, E>
Implementors
impl Exec for VecDequeChannel
[src]
fn submit(&self, task: RunningTask)
[src]
fn exec(
&self,
future: impl Future<Item = (), Error = ()> + Send + 'static
)
[src]
&self,
future: impl Future<Item = (), Error = ()> + Send + 'static
)
fn exec_push<I: Send + 'static, E: Send + 'static>(
&self,
future: impl Future<Item = I, Error = E> + Send + 'static
) -> PushFutureRecv<I, E>
[src]
&self,
future: impl Future<Item = I, Error = E> + Send + 'static
) -> PushFutureRecv<I, E>