Trait task_exec_queue::SpawnExt
source · [−]pub trait SpawnExt: Future {
fn spawn<Tx, G>(
self,
queue: &TaskExecQueue<Tx, G>
) -> Spawner<'_, Self, Tx, G, ()>ⓘNotable traits for Spawner<'_, Item, Tx, G, D>impl<Item, Tx, G, D> Future for Spawner<'_, Item, Tx, G, D>where
Item: Future + Send + 'static,
Item::Output: Send + 'static,
Tx: Clone + Unpin + Sink<(D, TaskType)> + Send + Sync + 'static,
G: Hash + Eq + Clone + Debug + Send + Sync + 'static, type Output = Result<(), Error<Item>>;
where
Self: Sized + Send + 'static,
Self::Output: Send + 'static,
Tx: Clone + Unpin + Sink<((), TaskType)> + Send + Sync + 'static,
G: Hash + Eq + Clone + Debug + Send + Sync + 'static,
{ ... }
fn spawn_with<Tx, G, D>(
self,
queue: &TaskExecQueue<Tx, G, D>,
name: D
) -> Spawner<'_, Self, Tx, G, D>ⓘNotable traits for Spawner<'_, Item, Tx, G, D>impl<Item, Tx, G, D> Future for Spawner<'_, Item, Tx, G, D>where
Item: Future + Send + 'static,
Item::Output: Send + 'static,
Tx: Clone + Unpin + Sink<(D, TaskType)> + Send + Sync + 'static,
G: Hash + Eq + Clone + Debug + Send + Sync + 'static, type Output = Result<(), Error<Item>>;
where
Self: Sized + Send + 'static,
Self::Output: Send + 'static,
Tx: Clone + Unpin + Sink<(D, TaskType)> + Send + Sync + 'static,
G: Hash + Eq + Clone + Debug + Send + Sync + 'static,
{ ... }
}
Provided Methods
fn spawn<Tx, G>(
self,
queue: &TaskExecQueue<Tx, G>
) -> Spawner<'_, Self, Tx, G, ()>ⓘNotable traits for Spawner<'_, Item, Tx, G, D>impl<Item, Tx, G, D> Future for Spawner<'_, Item, Tx, G, D>where
Item: Future + Send + 'static,
Item::Output: Send + 'static,
Tx: Clone + Unpin + Sink<(D, TaskType)> + Send + Sync + 'static,
G: Hash + Eq + Clone + Debug + Send + Sync + 'static, type Output = Result<(), Error<Item>>;
where
Self: Sized + Send + 'static,
Self::Output: Send + 'static,
Tx: Clone + Unpin + Sink<((), TaskType)> + Send + Sync + 'static,
G: Hash + Eq + Clone + Debug + Send + Sync + 'static,
Item: Future + Send + 'static,
Item::Output: Send + 'static,
Tx: Clone + Unpin + Sink<(D, TaskType)> + Send + Sync + 'static,
G: Hash + Eq + Clone + Debug + Send + Sync + 'static, type Output = Result<(), Error<Item>>;
fn spawn_with<Tx, G, D>(
self,
queue: &TaskExecQueue<Tx, G, D>,
name: D
) -> Spawner<'_, Self, Tx, G, D>ⓘNotable traits for Spawner<'_, Item, Tx, G, D>impl<Item, Tx, G, D> Future for Spawner<'_, Item, Tx, G, D>where
Item: Future + Send + 'static,
Item::Output: Send + 'static,
Tx: Clone + Unpin + Sink<(D, TaskType)> + Send + Sync + 'static,
G: Hash + Eq + Clone + Debug + Send + Sync + 'static, type Output = Result<(), Error<Item>>;
where
Self: Sized + Send + 'static,
Self::Output: Send + 'static,
Tx: Clone + Unpin + Sink<(D, TaskType)> + Send + Sync + 'static,
G: Hash + Eq + Clone + Debug + Send + Sync + 'static,
Item: Future + Send + 'static,
Item::Output: Send + 'static,
Tx: Clone + Unpin + Sink<(D, TaskType)> + Send + Sync + 'static,
G: Hash + Eq + Clone + Debug + Send + Sync + 'static, type Output = Result<(), Error<Item>>;