| /external/rust/crates/futures-util/src/stream/stream/ |
| D | mod.rs | 28 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
32 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
36 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
40 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
44 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
48 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
52 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
56 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
70 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
87 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
[all …]
|
| /external/rust/crates/futures/ |
| D | Cargo.toml | 9 # issue against the rust-lang/cargo repository. If you're
18 …of futures and streams featuring zero allocations,\ncomposability, and iterator-like interfaces.\n"
19 homepage = "https://rust-lang.github.io/futures-rs"
24 license = "MIT OR Apache-2.0"
25 repository = "https://github.com/rust-lang/futures-rs"
27 all-features = true
28 rustdoc-args = ["--cfg", "docsrs"]
31 features = ["std", "async-await", "compat", "io-compat", "executor", "thread-pool"]
32 [dependencies.futures-channel]
35 default-features = false
[all …]
|
| D | Cargo.toml.orig | 6 license = "MIT OR Apache-2.0"
9 repository = "https://github.com/rust-lang/futures-rs"
10 homepage = "https://rust-lang.github.io/futures-rs"
14 composability, and iterator-like interfaces.
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…
23 futures-io = { path = "../futures-io", version = "0.3.13", default-features = false }
24 futures-sink = { path = "../futures-sink", version = "0.3.13", default-features = false }
[all …]
|
| /external/rust/crates/instant/.circleci/ |
| D | config.yml | 4 rust-executor:
6 - image: rust:latest
10 executor: rust-executor
12 - checkout
13 - run:
14 name: install cargo-web
15 command: cargo install -f cargo-web;
16 - run:
18 command: cargo build --verbose;
19 - run:
[all …]
|
| /external/libchromeos-rs/ |
| D | Cargo.lock | 10 source = "registry+https://github.com/rust-lang/crates.io-index"
14 name = "cfg-if"
16 source = "registry+https://github.com/rust-lang/crates.io-index"
30 source = "registry+https://github.com/rust-lang/crates.io-index"
33 "futures-channel",
34 "futures-core",
35 "futures-executor",
36 "futures-io",
37 "futures-sink",
38 "futures-task",
[all …]
|
| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | mod.rs | 4 //! that return `Result`s, allowing for short-circuiting computations.
22 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
47 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
65 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
69 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
73 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
77 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
81 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
85 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
89 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
[all …]
|
| /external/rust/crates/futures-util/src/compat/ |
| D | executor.rs | 6 use futures_01::future::{ExecuteError as ExecuteError01, Executor as Executor01};
11 /// [`Executor`](futures_01::future::Executor).
14 /// Extension trait for futures 0.1 [`Executor`](futures_01::future::Executor).
16 /// Converts a futures 0.1 [`Executor`](futures_01::future::Executor) into a
23 /// use tokio::executor::DefaultExecutor;
39 /// # futures::executor::block_on(rx).unwrap();
41 fn compat(self) -> Executor01As03<Self> in compat()
50 fn compat(self) -> Executor01As03<Self> { in compat()
55 /// Converts a futures 0.1 [`Executor`](futures_01::future::Executor) into a
66 fn spawn_obj(&self, future: FutureObj<'static, ()>) -> Result<(), SpawnError03> { in spawn_obj()
[all …]
|
| D | compat01as03.rs | 1 use futures_01::executor::{
17 #[cfg(feature = "io-compat")]
18 #[cfg_attr(docsrs, doc(cfg(feature = "io-compat")))]
19 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
23 /// object to a futures 0.3-compatible version,
34 /// object in a futures 0.3-compatible wrapper.
35 pub fn new(object: T) -> Self { in new()
41 fn in_notify<R>(&mut self, cx: &mut Context<'_>, f: impl FnOnce(&mut T) -> R) -> R { in in_notify()
47 pub fn get_ref(&self) -> &T { in get_ref()
53 pub fn get_mut(&mut self) -> &mut T { in get_mut()
[all …]
|
| /external/rust/crates/futures-executor/ |
| D | Cargo.toml | 9 # issue against the rust-lang/cargo repository. If you're
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"
21 license = "MIT OR Apache-2.0"
22 repository = "https://github.com/rust-lang/futures-rs"
24 all-features = true
25 rustdoc-args = ["--cfg", "docsrs"]
26 [dependencies.futures-core]
[all …]
|
| D | Cargo.toml.orig | 2 name = "futures-executor"
6 license = "MIT OR Apache-2.0"
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"]
17 thread-pool = ["std", "num_cpus"]
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 }
[all …]
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | mod.rs | 45 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
100 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
110 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
116 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
138 /// # futures::executor::block_on(async {
146 fn map<U, F>(self, f: F) -> Map<Self, F> in map()
148 F: FnOnce(Self::Output) -> U, in map()
159 fn map_into<U>(self) -> MapInto<Self, U> in map_into()
183 /// # futures::executor::block_on(async {
191 fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> in then()
[all …]
|
| /external/rust/crates/futures/tests/ |
| D | try_join.rs | 3 use futures::{try_join, executor::block_on};
5 // TODO: This abuses https://github.com/rust-lang/rust/issues/58733 in order to
12 impl<T> MyTrait for fn() -> T {
15 type Never = <fn() -> ! as MyTrait>::Output;
|
| /external/rust/crates/tokio/src/task/ |
| D | mod.rs | 1 //! Asynchronous green-threads.
5 //! A _task_ is a light weight, non-blocking unit of execution. A task is similar
30 //! * Tasks are **non-blocking**. Typically, when an OS thread performs I/O or
42 //! [Kotlin's coroutines]: https://kotlinlang.org/docs/reference/coroutines-overview.html
73 //! # #[tokio::main] async fn main() -> Result<(), Box<dyn std::error::Error>> {
129 //! _non-blocking_ future on the Tokio runtime, it instead spawns a
138 //! // do some compute-heavy work or call synchronous code
146 //! ```rust
148 //! # async fn docs() -> Result<(), Box<dyn std::error::Error>>{
150 //! // do some compute-heavy work or call synchronous code
[all …]
|
| /external/crosvm/arch/ |
| D | Android.bp | 1 … generated by cargo2android.py --run --device --tests --dependencies --global_defaults=crosvm_defa…
2 // NOTE: The --features=gdb should be applied only to the host (not the device) and there are inlin…
5 // See: http://go/android-license-faq
6 // A large-scale-change added 'default_applicable_licenses' to import
9 // SPDX-license-identifier-BSD
18 test_suites: ["general-tests"],
105 // ../../adhd/cras/client/cras-sys/src/lib.rs
107 // ../../libchromeos-rs/src/lib.rs
108 // ../../minijail/rust/minijail-sys/lib.rs
109 // ../../minijail/rust/minijail/src/lib.rs
[all …]
|
| /external/crosvm/aarch64/ |
| D | Android.bp | 1 … file is generated by cargo2android.py --run --device --tests --dependencies --global_defaults=cro…
4 // See: http://go/android-license-faq
5 // A large-scale-change added 'default_applicable_licenses' to import
8 // SPDX-license-identifier-BSD
18 test_suites: ["general-tests"],
108 // ../../adhd/cras/client/cras-sys/src/lib.rs
110 // ../../libchromeos-rs/src/lib.rs
111 // ../../minijail/rust/minijail-sys/lib.rs
112 // ../../minijail/rust/minijail/src/lib.rs
151 // async-task-4.0.3 "default,std"
[all …]
|
| /external/rust/crates/async-task/ |
| D | README.md | 1 # async-task
3 [](
4 https://github.com/smol-rs/async-task/actions)
5 [](
6 https://github.com/smol-rs/async-task)
7 [](
8 https://crates.io/crates/async-task)
9 [](
10 https://docs.rs/async-task)
14 To spawn a future onto an executor, we first need to allocate it on the heap and keep some
[all …]
|
| /external/crosvm/x86_64/ |
| D | Android.bp | 1 … generated by cargo2android.py --run --device --tests --dependencies --global_defaults=crosvm_defa…
2 // NOTE: The --features=gdb should be applied only to the host (not the device) and there are inlin…
5 // See: http://go/android-license-faq
6 // A large-scale-change added 'default_applicable_licenses' to import
9 // SPDX-license-identifier-BSD
66 test_suites: ["general-tests"],
124 // ../../adhd/cras/client/cras-sys/src/lib.rs
126 // ../../libchromeos-rs/src/lib.rs
127 // ../../minijail/rust/minijail-sys/lib.rs
128 // ../../minijail/rust/minijail/src/lib.rs
[all …]
|
| /external/crosvm/devices/ |
| D | Android.bp | 1 … file is generated by cargo2android.py --run --device --tests --dependencies --global_defaults=cro…
5 // See: http://go/android-license-faq
6 // A large-scale-change added 'default_applicable_licenses' to import
9 // SPDX-license-identifier-BSD
19 test_suites: ["general-tests"],
170 // ../../adhd/cras/client/cras-sys/src/lib.rs
172 // ../../libchromeos-rs/src/lib.rs
173 // ../../minijail/rust/minijail-sys/lib.rs
174 // ../../minijail/rust/minijail/src/lib.rs
210 // async-task-4.0.3 "default,std"
[all …]
|
| /external/rust/crates/futures/src/ |
| D | lib.rs | 6 //! - [Futures](crate::future::Future) are single eventual values produced by
9 //! - [Streams](crate::stream::Stream) represent a series of values
11 //! - [Sinks](crate::sink::Sink) provide support for asynchronous writing of
13 //! - [Executors](crate::executor) are responsible for running asynchronous
17 //! [cross-task communication](crate::channel).
27 //! ```rust
29 //! # use futures::executor; ///standard executors to provide a context for futures and streams
30 //! # use futures::executor::ThreadPool;
38 //! // implementation of Future. At this point no executor has been provided
43 //! // it will be provided with the executor of the parent block when the parent
[all …]
|
| /external/rust/crates/futures-util/src/io/ |
| D | mod.rs | 19 #[cfg(feature = "io-compat")]
20 #[cfg_attr(docsrs, doc(cfg(feature = "io-compat")))]
26 // Re-export some types from `std::io` so that users don't have to deal
31 #[cfg(feature = "read-initializer")]
32 #[cfg_attr(docsrs, doc(cfg(feature = "read-initializer")))]
38 // https://github.com/rust-lang/rust/blob/master/src/libstd/sys_common/io.rs#L1
43 /// A buffer is always initialized if `read-initializer` feature is disabled.
46 #[cfg(feature = "read-initializer")] in initialize()
146 #[cfg(feature = "write-all-vectored")]
148 #[cfg(feature = "write-all-vectored")]
[all …]
|
| /external/crosvm/ |
| D | Android.bp | 1 // This file is generated by cargo2android.py --run --device --tests --dependencies --no-subdir.
12 // * Use --no-subdir to suppress output of subdirectory Android.bp files.
19 // Added automatically by a large-scale-change that took the approach of
32 // See: http://go/android-license-faq
37 "SPDX-license-identifier-Apache-2.0",
38 "SPDX-license-identifier-BSD",
39 "SPDX-license-identifier-MIT",
54 "-L device/google/cuttlefish_vmm/x86_64-linux-gnu/bin/",
94 relative_install_path: "aarch64-linux-bionic",
101 relative_install_path: "x86_64-linux-gnu",
[all …]
|
| /external/rust/crates/criterion/ |
| D | Cargo.toml | 9 # issue against the rust-lang/cargo repository. If you're
19 description = "Statistics-driven micro-benchmarking library"
23 categories = ["development-tools::profiling"]
24 license = "Apache-2.0/MIT"
35 [dependencies.async-std]
47 default-features = false
49 [dependencies.criterion-plot]
66 [dependencies.num-traits]
68 default-features = false
76 default-features = false
[all …]
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | mod.rs | 6 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
13 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
57 /// Bind a task to the executor.
62 fn bind(task: Task<Self>) -> Self; in bind()
69 /// the ref-dec with other options.
70 fn release(&self, task: &Task<Self>) -> Option<Task<Self>>; in release()
84 pub(crate) fn joinable<T, S>(task: T) -> (Notified<S>, JoinHandle<T::Output>)
104 pub(crate) unsafe fn joinable_local<T, S>(task: T) -> (Notified<S>, JoinHandle<T::Output>)
123 pub(crate) unsafe fn from_raw(ptr: NonNull<Header>) -> Task<S> { in from_raw()
130 pub(crate) fn header(&self) -> &Header { in header()
[all …]
|
| /external/rust/crates/futures-util/src/stream/ |
| D | repeat_with.rs | 7 /// applying the provided closure `F: FnMut() -> A`.
17 impl<A, F: FnMut() -> A> Unpin for RepeatWith<F> {}
19 impl<A, F: FnMut() -> A> Stream for RepeatWith<F> {
22 fn poll_next(mut self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next()
26 fn size_hint(&self) -> (usize, Option<usize>) { in size_hint()
31 impl<A, F: FnMut() -> A> FusedStream for RepeatWith<F>
33 fn is_terminated(&self) -> bool { in is_terminated()
39 /// applying the provided closure, the repeater, `F: FnMut() -> A`.
55 /// # futures::executor::block_on(async {
74 /// ```rust
[all …]
|
| D | iter.rs | 18 /// Iterators in Rust don't express the ability to block, so this adapter
22 /// # futures::executor::block_on(async {
29 pub fn iter<I>(i: I) -> Iter<I::IntoIter> in iter()
42 fn poll_next(mut self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Option<I::Item>> { in poll_next()
46 fn size_hint(&self) -> (usize, Option<usize>) { in size_hint()
|