| /external/rust/crates/futures/ |
| D | Cargo.toml.orig | 2 name = "futures"
8 keywords = ["futures", "async", "future"]
9 repository = "https://github.com/rust-lang/futures-rs"
10 homepage = "https://rust-lang.github.io/futures-rs"
11 documentation = "https://docs.rs/futures/0.3"
13 An implementation of futures and streams featuring zero allocations,
19 futures-core = { path = "../futures-core", version = "0.3.13", default-features = false }
20 futures-task = { path = "../futures-task", version = "0.3.13", default-features = false }
21 futures-channel = { path = "../futures-channel", version = "0.3.13", default-features = false, feat…
22 futures-executor = { path = "../futures-executor", version = "0.3.13", default-features = false, op…
[all …]
|
| D | Cargo.toml | 15 name = "futures"
18 description = "An implementation of futures and streams featuring zero allocations,\ncomposability,…
19 homepage = "https://rust-lang.github.io/futures-rs"
20 documentation = "https://docs.rs/futures/0.3"
22 keywords = ["futures", "async", "future"]
25 repository = "https://github.com/rust-lang/futures-rs"
32 [dependencies.futures-channel]
37 [dependencies.futures-core]
41 [dependencies.futures-executor]
46 [dependencies.futures-io]
[all …]
|
| D | Android.bp | 43 crate_name: "futures",
51 "futures-executor",
70 // futures-channel-0.3.14 "alloc,futures-sink,sink,std"
71 // futures-core-0.3.14 "alloc,std"
72 // futures-executor-0.3.14 "std"
73 // futures-io-0.3.14 "std"
74 // futures-macro-0.3.14
75 // futures-sink-0.3.14 "alloc,std"
76 // futures-task-0.3.14 "alloc,std"
77 // futures-util-0.3.14 "alloc,async-await,async-await-macro,channel,futures-channel,futures-io,fu…
|
| /external/rust/crates/futures-util/ |
| D | Cargo.toml.orig | 2 name = "futures-util"
7 repository = "https://github.com/rust-lang/futures-rs"
8 homepage = "https://rust-lang.github.io/futures-rs"
9 documentation = "https://docs.rs/futures-util/0.3"
11 Common utilities and extension traits for the futures-rs library.
16 std = ["alloc", "futures-core/std", "futures-task/std", "slab"]
17 alloc = ["futures-core/alloc", "futures-task/alloc"]
19 async-await-macro = ["async-await", "futures-macro", "proc-macro-hack", "proc-macro-nested"]
22 sink = ["futures-sink"]
23 io = ["std", "futures-io", "memchr"]
[all …]
|
| D | Cargo.toml | 15 name = "futures-util"
18 description = "Common utilities and extension traits for the futures-rs library.\n"
19 homepage = "https://rust-lang.github.io/futures-rs"
20 documentation = "https://docs.rs/futures-util/0.3"
22 repository = "https://github.com/rust-lang/futures-rs"
26 [dependencies.futures-channel]
32 [dependencies.futures-core]
36 [dependencies.futures-io]
42 [dependencies.futures-macro]
47 [dependencies.futures-sink]
[all …]
|
| D | Android.bp | 41 name: "futures-util_defaults",
53 "futures-channel",
54 "futures-io",
55 "futures-macro",
56 "futures-sink",
85 name: "futures-util_host_test_src_lib",
86 defaults: ["futures-util_defaults"],
93 name: "futures-util_device_test_src_lib",
94 defaults: ["futures-util_defaults"],
109 "futures-channel",
[all …]
|
| /external/rust/crates/futures/tests/ |
| D | async_await_macros.rs | 3 use futures::{pending, pin_mut, poll}; in poll_and_pending()
4 use futures::executor::block_on; in poll_and_pending()
5 use futures::task::Poll; in poll_and_pending()
17 use futures::{pin_mut, poll, join}; in join()
18 use futures::channel::oneshot; in join()
19 use futures::executor::block_on; in join()
20 use futures::task::Poll; in join()
42 use futures::select; in select()
43 use futures::channel::oneshot; in select()
44 use futures::executor::block_on; in select()
[all …]
|
| D | sink.rs | 2 use futures::stream::{Stream, StreamExt};
3 use futures::task::Poll;
21 use futures::task::Poll;
34 use futures::task::{self, ArcWake, Context};
73 use futures::future::Future;
74 use futures::ready;
75 use futures::sink::Sink;
76 use futures::task::{Context, Poll};
104 use futures::sink::Sink;
105 use futures::task::{Context, Poll, Waker};
[all …]
|
| D | shared.rs | 16 use futures::channel::oneshot; in send_shared_oneshot_and_wait_on_multiple_threads()
17 use futures::executor::block_on; in send_shared_oneshot_and_wait_on_multiple_threads()
18 use futures::future::FutureExt; in send_shared_oneshot_and_wait_on_multiple_threads()
56 use futures::channel::oneshot; in drop_on_one_task_ok()
57 use futures::executor::block_on; in drop_on_one_task_ok()
58 use futures::future::{self, FutureExt, TryFutureExt}; in drop_on_one_task_ok()
89 use futures::executor::block_on; in drop_in_poll()
90 use futures::future::{self, FutureExt, LocalFutureObj}; in drop_in_poll()
111 use futures::channel::oneshot; in peek()
112 use futures::executor::LocalPool; in peek()
[all …]
|
| D | futures_unordered.rs | 1 use futures::future::Future;
2 use futures::stream::{FuturesUnordered, StreamExt};
3 use futures::task::{Context, Poll};
10 use futures::future; in is_terminated()
11 use futures::stream::{FusedStream, FuturesUnordered, StreamExt}; in is_terminated()
12 use futures::task::Poll; in is_terminated()
42 use futures::channel::oneshot; in works_1()
43 use futures::executor::block_on_stream; in works_1()
44 use futures::stream::FuturesUnordered; in works_1()
68 use futures::channel::oneshot; in works_2()
[all …]
|
| D | stream.rs | 3 use futures::executor::block_on; in select()
4 use futures::stream::{self, StreamExt}; in select()
20 use futures::stream::{self, StreamExt}; in flat_map()
22 futures::executor::block_on(async { in flat_map()
30 .flat_map(|s| s.filter(|v| futures::future::ready(v % 2 == 0))) in flat_map()
40 use futures::stream::{self, StreamExt}; in scan()
42 futures::executor::block_on(async { in scan()
47 futures::future::ready(if e < *state { Some(e) } else { None }) in scan()
58 use futures::future::{self, Future}; in take_until()
59 use futures::stream::{self, StreamExt}; in take_until()
[all …]
|
| D | ready_queue.rs | 2 use futures::stream::FuturesUnordered;
10 use futures::channel::oneshot; in basic_usage()
11 use futures::executor::block_on; in basic_usage()
12 use futures::future; in basic_usage()
13 use futures::stream::{FuturesUnordered, StreamExt}; in basic_usage()
14 use futures::task::Poll; in basic_usage()
44 use futures::channel::oneshot; in resolving_errors()
45 use futures::executor::block_on; in resolving_errors()
46 use futures::future; in resolving_errors()
47 use futures::stream::{FuturesUnordered, StreamExt}; in resolving_errors()
[all …]
|
| D | mutex.rs | 3 use futures::future::FutureExt; in mutex_acquire_uncontested()
4 use futures::lock::Mutex; in mutex_acquire_uncontested()
15 use futures::future::FutureExt; in mutex_wakes_waiters()
16 use futures::lock::Mutex; in mutex_wakes_waiters()
17 use futures::task::Context; in mutex_wakes_waiters()
38 use futures::channel::mpsc; in mutex_contested()
39 use futures::executor::block_on; in mutex_contested()
40 use futures::future::ready; in mutex_contested()
41 use futures::lock::Mutex; in mutex_contested()
42 use futures::stream::StreamExt; in mutex_contested()
[all …]
|
| D | abortable.rs | 3 use futures::channel::oneshot; in abortable_works()
4 use futures::future::{abortable, Aborted}; in abortable_works()
5 use futures::executor::block_on; in abortable_works()
16 use futures::channel::oneshot; in abortable_awakens()
17 use futures::future::{abortable, Aborted, FutureExt}; in abortable_awakens()
18 use futures::task::{Context, Poll}; in abortable_awakens()
36 use futures::channel::oneshot; in abortable_resolves()
37 use futures::future::abortable; in abortable_resolves()
38 use futures::executor::block_on; in abortable_resolves()
|
| D | stream_select_next_some.rs | 3 use futures::future; in is_terminated()
4 use futures::future::{FusedFuture, FutureExt}; in is_terminated()
5 use futures::stream::{FuturesUnordered, StreamExt}; in is_terminated()
6 use futures::task::{Context, Poll}; in is_terminated()
33 use futures::{future, select}; in select()
34 use futures::stream::{FuturesUnordered, StreamExt}; in select()
41 futures::executor::block_on(async { in select()
64 use futures::future; in futures_util_select()
65 use futures::stream::{FuturesUnordered, StreamExt}; in futures_util_select()
74 futures::executor::block_on(async { in futures_util_select()
|
| /external/rust/crates/futures-channel/ |
| D | Cargo.toml.orig | 2 name = "futures-channel"
7 repository = "https://github.com/rust-lang/futures-rs"
8 homepage = "https://rust-lang.github.io/futures-rs"
9 documentation = "https://docs.rs/futures-channel/0.3"
11 Channels for asynchronous communication using futures-rs.
16 std = ["alloc", "futures-core/std"]
17 alloc = ["futures-core/alloc"]
18 sink = ["futures-sink"]
23 unstable = ["futures-core/unstable"]
24 cfg-target-has-atomic = ["futures-core/cfg-target-has-atomic"]
[all …]
|
| D | Cargo.toml | 15 name = "futures-channel"
18 description = "Channels for asynchronous communication using futures-rs.\n"
19 homepage = "https://rust-lang.github.io/futures-rs"
20 documentation = "https://docs.rs/futures-channel/0.3"
22 repository = "https://github.com/rust-lang/futures-rs"
26 [dependencies.futures-core]
30 [dependencies.futures-sink]
38 alloc = ["futures-core/alloc"]
39 cfg-target-has-atomic = ["futures-core/cfg-target-has-atomic"]
41 sink = ["futures-sink"]
[all …]
|
| /external/rust/crates/futures-executor/ |
| D | Cargo.toml.orig | 2 name = "futures-executor"
7 repository = "https://github.com/rust-lang/futures-rs"
8 homepage = "https://rust-lang.github.io/futures-rs"
9 documentation = "https://docs.rs/futures-executor/0.3"
11 Executors for asynchronous tasks based on the futures-rs library.
16 std = ["futures-core/std", "futures-task/std", "futures-util/std"]
20 futures-core = { path = "../futures-core", version = "0.3.13", default-features = false }
21 futures-task = { path = "../futures-task", version = "0.3.13", default-features = false }
22 futures-util = { path = "../futures-util", version = "0.3.13", default-features = false }
26 futures = { path = "../futures" }
|
| D | Cargo.toml | 15 name = "futures-executor"
18 description = "Executors for asynchronous tasks based on the futures-rs library.\n"
19 homepage = "https://rust-lang.github.io/futures-rs"
20 documentation = "https://docs.rs/futures-executor/0.3"
22 repository = "https://github.com/rust-lang/futures-rs"
26 [dependencies.futures-core]
30 [dependencies.futures-task]
34 [dependencies.futures-util]
46 std = ["futures-core/std", "futures-task/std", "futures-util/std"]
|
| /external/libchromeos-rs/ |
| D | Cargo.lock | 28 name = "futures"
33 "futures-channel",
34 "futures-core",
35 "futures-executor",
36 "futures-io",
37 "futures-sink",
38 "futures-task",
39 "futures-util",
43 name = "futures-channel"
48 "futures-core",
[all …]
|
| D | Android.bp | 72 // futures-0.3.9 "alloc,async-await,default,executor,futures-executor,std"
73 // futures-channel-0.3.9 "alloc,futures-sink,sink,std"
74 // futures-core-0.3.9 "alloc,std"
75 // futures-executor-0.3.9 "default,num_cpus,std,thread-pool"
76 // futures-io-0.3.9 "std"
77 // futures-macro-0.3.9
78 // futures-sink-0.3.9 "alloc,std"
79 // futures-task-0.3.9 "alloc,once_cell,std"
80 // futures-util-0.3.9 "alloc,async-await,async-await-macro,channel,default,futures-channel,future…
|
| /external/rust/crates/grpcio/ |
| D | Android.bp | 46 // futures-0.3.13 "alloc,async-await,default,executor,futures-executor,std"
47 // futures-channel-0.3.13 "alloc,futures-sink,sink,std"
48 // futures-core-0.3.13 "alloc,std"
49 // futures-executor-0.3.13 "std"
50 // futures-io-0.3.13 "std"
51 // futures-macro-0.3.13
52 // futures-sink-0.3.13 "alloc,std"
53 // futures-task-0.3.13 "alloc,std"
54 // futures-util-0.3.13 "alloc,async-await,async-await-macro,channel,futures-channel,futures-io,fu…
|
| /external/crosvm/cros_async/ |
| D | Android.bp | 99 // futures-0.3.13 "alloc,async-await,default,executor,futures-executor,std"
100 // futures-channel-0.3.13 "alloc,futures-sink,sink,std"
101 // futures-core-0.3.13 "alloc,std"
102 // futures-executor-0.3.13 "std"
103 // futures-io-0.3.13 "std"
104 // futures-macro-0.3.13
105 // futures-sink-0.3.13 "alloc,std"
106 // futures-task-0.3.13 "alloc,std"
107 // futures-util-0.3.13 "alloc,async-await,async-await-macro,channel,futures-channel,futures-io,fu…
|
| /external/python/futures/futures.egg-info/ |
| D | SOURCES.txt | 11 concurrent/futures/__init__.py
12 concurrent/futures/_base.py
13 concurrent/futures/process.py
14 concurrent/futures/thread.py
19 futures.egg-info/PKG-INFO
20 futures.egg-info/SOURCES.txt
21 futures.egg-info/dependency_links.txt
22 futures.egg-info/not-zip-safe
23 futures.egg-info/top_level.txt
|
| /external/python/futures/ |
| D | test_futures.py | 15 from concurrent import futures
16 from concurrent.futures._base import (
18 from concurrent.futures.thread import cpu_count
158 futures = [self.executor.submit(time.sleep, 0.1)
161 for f in futures:
166 executor_type = futures.ThreadPoolExecutor
170 executor_type = futures.ProcessPoolExecutor
215 with futures.ThreadPoolExecutor(max_workers=5) as e:
224 executor = futures.ThreadPoolExecutor(max_workers=5)
234 executor = futures.ThreadPoolExecutor(
[all …]
|