[−][src]Trait smartpool::channel::ExecParam
Trait for channels for which a task can be submitted along side an additional parameter.
Associated Types
type Param
Required methods
fn submit(&self, task: RunningTask, param: Self::Param)
Submit a raw running task.
Provided methods
fn exec(
&self,
future: impl Future<Item = (), Error = ()> + Send + 'static,
param: Self::Param
)
&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>
&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.
Implementations on Foreign Types
impl<E: ExecParam> ExecParam for Arc<RwLock<E>>
[src]
Shared exec param implementation.
type Param = E::Param
fn submit(&self, task: RunningTask, param: E::Param)
[src]
fn exec(
&self,
future: impl Future<Item = (), Error = ()> + Send + 'static,
param: Self::Param
)
[src]
&self,
future: impl Future<Item = (), Error = ()> + Send + 'static,
param: Self::Param
)
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>
[src]
&self,
future: impl Future<Item = I, Error = E> + Send + 'static,
param: Self::Param
) -> PushFutureRecv<I, E>
Implementors
impl ExecParam for ShortestDeadlineFirst
[src]
type Param = SteadyTime
fn submit(&self, task: RunningTask, deadline: SteadyTime)
[src]
fn exec(
&self,
future: impl Future<Item = (), Error = ()> + Send + 'static,
param: Self::Param
)
[src]
&self,
future: impl Future<Item = (), Error = ()> + Send + 'static,
param: Self::Param
)
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>
[src]
&self,
future: impl Future<Item = I, Error = E> + Send + 'static,
param: Self::Param
) -> PushFutureRecv<I, E>
impl<Inner: Channel + ExecParam> ExecParam for MultiChannel<Inner>
[src]
type Param = Inner::Param
fn submit(&self, task: RunningTask, param: Self::Param)
[src]
fn exec(
&self,
future: impl Future<Item = (), Error = ()> + Send + 'static,
param: Self::Param
)
[src]
&self,
future: impl Future<Item = (), Error = ()> + Send + 'static,
param: Self::Param
)
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>
[src]
&self,
future: impl Future<Item = I, Error = E> + Send + 'static,
param: Self::Param
) -> PushFutureRecv<I, E>