Searched refs:LocalPool (Results 1 – 9 of 9) sorted by relevance
| /external/rust/android-crates-io/crates/futures-executor/tests/ |
| D | local_pool.rs | 2 use futures::executor::LocalPool;
33 let mut pool = LocalPool::new(); in run_until_single_future()
45 let mut pool = LocalPool::new(); in run_until_ignores_spawned()
54 let mut pool = LocalPool::new(); in run_until_executes_spawned()
69 let mut pool = LocalPool::new(); in run_returns_if_empty()
79 let mut pool = LocalPool::new(); in run_executes_spawned()
110 let mut pool = LocalPool::new(); in run_spawn_many()
132 let mut pool = LocalPool::new(); in try_run_one_returns_if_empty()
142 let mut pool = LocalPool::new(); in try_run_one_executes_one_ready()
175 let mut pool = LocalPool::new(); in try_run_one_returns_on_no_progress()
[all …]
|
| /external/rust/android-crates-io/crates/tokio-util/src/task/ |
| D | spawn_pinned.rs | 52 pool: Arc<LocalPool>,
70 let pool = Arc::new(LocalPool { workers }); in new()
196 struct LocalPool { struct
200 impl LocalPool { implementation
|
| /external/rust/android-crates-io/crates/futures-executor/src/ |
| D | local_pool.rs | 32 pub struct LocalPool { struct
110 impl LocalPool { impl
303 impl Default for LocalPool { implementation
357 LocalPool::new().run_until(self.stream.next()) in next()
|
| D | lib.rs | 56 pub use crate::local_pool::{block_on, block_on_stream, BlockingStream, LocalPool, LocalSpawner};
|
| /external/rust/android-crates-io/crates/futures/tests/ |
| D | future_shared.rs | 2 use futures::executor::{block_on, LocalPool};
102 let mut local_pool = LocalPool::new(); in peek()
|
| D | auto_traits.rs | 205 assert_not_impl!(LocalPool: Send);
206 assert_not_impl!(LocalPool: Sync);
207 assert_impl!(LocalPool: Unpin);
|
| /external/rust/android-crates-io/crates/futures/src/ |
| D | lib.rs | 191 block_on, block_on_stream, enter, BlockingStream, Enter, EnterError, LocalPool,
|
| /external/crosvm/cros_async/src/sync/ |
| D | cv.rs | 490 use futures_executor::LocalPool;
601 let mut ex = LocalPool::new(); in notify_one_single_thread_async()
898 let mut ex = LocalPool::new(); in notify_all_single_thread_async()
|
| D | mu.rs | 936 use futures_executor::LocalPool;
999 let mut ex = LocalPool::new(); in async_smoke()
1153 let mut ex = LocalPool::new(); in single_thread_async()
1337 let mut ex = LocalPool::new(); in rw_single_thread_async()
|