Searched defs:spawner (Results 1 – 11 of 11) sorted by relevance
161 PromiseSpawner spawner, FirstFollowUp first, in WrapFollowUps()182 PromiseSpawner spawner, First first, FollowUps... followups) { in StartSeq()
463 let spawner = pool.spawner(); in self_waking_run_until_stalled() localVariable484 let spawner = pool.spawner(); in self_waking_try_run_one() localVariable
2520 Party::BulkSpawner& spawner) { in StartSendMessage()2549 Party::BulkSpawner& spawner) { in StartRecvMessage()2774 Party::BulkSpawner& spawner) { in StartPromise()2845 Party::BulkSpawner spawner(this); in CommitBatch() local2929 Party::BulkSpawner& spawner) { in StartRecvInitialMetadata()3000 Party::BulkSpawner& spawner) { in StartRecvStatusOnClient()3302 Party::BulkSpawner spawner(this); in CommitBatch() local
20 spawner: Spawner, field240 pub(crate) fn spawner(&self) -> &Spawner { in spawner() method
2584 Party::BulkSpawner& spawner) { in StartSendMessage()2613 Party::BulkSpawner& spawner) { in StartRecvMessage()2955 Party::BulkSpawner& spawner) { in StartPromise()3036 Party::BulkSpawner spawner(this); in CommitBatch() local3123 Party::BulkSpawner& spawner) { in StartRecvInitialMetadata()3209 Party::BulkSpawner& spawner) { in StartRecvStatusOnClient()3522 Party::BulkSpawner spawner(this); in CommitBatch() local
172 public final void setTrackingSpawner(LaunchProjectileComponent spawner) { in setTrackingSpawner()
1000 let spawner = ex.spawner(); in async_smoke() localVariable1154 let spawner = ex.spawner(); in single_thread_async() localVariable1338 let spawner = ex.spawner(); in rw_single_thread_async() localVariable
602 let spawner = ex.spawner(); in notify_one_single_thread_async() localVariable899 let spawner = ex.spawner(); in notify_all_single_thread_async() localVariable
470 Party::BulkSpawner spawner(party.get()); in TEST_F() local489 Party::BulkSpawner spawner(party.get()); in TEST_F() local
365 spawner: UnboundedSender<PinnedFutureSpawner>, field
117 pub fn spawner(&self) -> LocalSpawner { in spawner() method