| /external/rust/crates/futures/ |
| D | Cargo.toml.orig | 5 rust-version = "1.56"
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"
13 composability, and iterator-like interfaces.
18 futures-core = { path = "../futures-core", version = "0.3.30", default-features = false }
19 futures-task = { path = "../futures-task", version = "0.3.30", default-features = false }
20 futures-channel = { path = "../futures-channel", version = "0.3.30", default-features = false, feat…
21 futures-executor = { path = "../futures-executor", version = "0.3.30", default-features = false, op…
22 futures-io = { path = "../futures-io", version = "0.3.30", default-features = false }
[all …]
|
| D | Cargo.toml | 14 rust-version = "1.56"
19 composability, and iterator-like interfaces.
21 homepage = "https://rust-lang.github.io/futures-rs"
29 license = "MIT OR Apache-2.0"
30 repository = "https://github.com/rust-lang/futures-rs"
33 all-features = true
34 rustdoc-args = [
35 "--cfg",
42 "async-await",
44 "io-compat",
[all …]
|
| /external/bazelbuild-rules_rust/proto/protobuf/3rdparty/ |
| D | Cargo.Bazel.lock | 8 source = "registry+https://github.com/rust-lang/crates.io-index"
14 source = "registry+https://github.com/rust-lang/crates.io-index"
24 source = "registry+https://github.com/rust-lang/crates.io-index"
30 source = "registry+https://github.com/rust-lang/crates.io-index"
36 source = "registry+https://github.com/rust-lang/crates.io-index"
44 name = "cfg-if"
46 source = "registry+https://github.com/rust-lang/crates.io-index"
50 name = "cfg-if"
52 source = "registry+https://github.com/rust-lang/crates.io-index"
58 source = "registry+https://github.com/rust-lang/crates.io-index"
[all …]
|
| /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
60 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
74 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
[all …]
|
| /external/rust/crates/futures-test/ |
| D | Cargo.toml.orig | 2 name = "futures-test"
5 rust-version = "1.56"
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"
10 Common utilities for testing components built off futures-rs.
14 futures-core = { version = "0.3.30", path = "../futures-core", default-features = false }
15 futures-task = { version = "0.3.30", path = "../futures-task", default-features = false }
16 futures-io = { version = "0.3.30", path = "../futures-io", default-features = false }
17 futures-util = { version = "0.3.30", path = "../futures-util", default-features = false }
[all …]
|
| D | Cargo.toml | 14 rust-version = "1.56"
15 name = "futures-test"
18 Common utilities for testing components built off futures-rs.
20 homepage = "https://rust-lang.github.io/futures-rs"
22 license = "MIT OR Apache-2.0"
23 repository = "https://github.com/rust-lang/futures-rs"
26 all-features = true
28 [dependencies.futures-core]
30 default-features = false
32 [dependencies.futures-executor]
[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/rust/crates/futures-util/src/stream/try_stream/ |
| D | mod.rs | 4 //! that return `Result`s, allowing for short-circuiting computations.
26 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
51 #[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
97 #[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
24 /// use tokio::executor::DefaultExecutor;
40 /// # futures::executor::block_on(rx).unwrap();
42 fn compat(self) -> Executor01As03<Self> in compat()
51 fn compat(self) -> Executor01As03<Self> { in compat()
56 /// Converts a futures 0.1 [`Executor`](futures_01::future::Executor) into a
67 fn spawn_obj(&self, future: FutureObj<'static, ()>) -> Result<(), SpawnError03> { in spawn_obj()
[all …]
|
| /external/rust/crates/uniffi_core/src/ffi/rustfuture/ |
| D | future.rs | 17 //! - Call [rust_future_poll]
18 //! - Suspend the function until the [rust_future_poll] continuation function is called
19 //! - If the continuation was function was called with [RustFuturePoll::Ready], then break
26 //! - Releases any resources held by the future
27 //! - Calls any continuation callbacks that have not been called yet
36 //! A [`Future`] in Rust does nothing. When calling an async function, it just
48 //! nothing? Well, it's _the executor_. The executor is responsible _to drive_ the
51 //! But… wait another minute… how does the executor know when to poll a [`Future`]?
53 //! on the executor! A well-designed `Future` and executor work as follows.
57 //! signal the executor to poll a particular `Future`. A `Future` will clone
[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-util/src/task/ |
| D | spawn.rs | 38 /// use futures::executor::ThreadPool;
41 /// let executor = ThreadPool::new().unwrap();
44 /// executor.spawn(future).unwrap();
46 …m_millis(500)); // wait for background threads closed: https://github.com/rust-lang/miri/issues/13…
49 fn spawn<Fut>(&self, future: Fut) -> Result<(), SpawnError> in spawn()
65 /// use futures::executor::{block_on, ThreadPool};
69 /// let executor = ThreadPool::new().unwrap();
72 /// let join_handle_fut = executor.spawn_with_handle(future).unwrap();
75 …m_millis(500)); // wait for background threads closed: https://github.com/rust-lang/miri/issues/13…
80 fn spawn_with_handle<Fut>(&self, future: Fut) -> Result<RemoteHandle<Fut::Output>, SpawnError> in spawn_with_handle()
[all …]
|
| /external/rust/crates/futures-executor/ |
| D | METADATA | 2 # Usage: tools/external_updater/updater.sh update external/rust/crates/futures-executor
5 name: "futures-executor"
6 description: "Executors for asynchronous tasks based on the futures-rs library."
14 homepage: "https://crates.io/crates/futures-executor"
17 value: "https://static.crates.io/crates/futures-executor/futures-executor-0.3.30.crate"
|
| /external/rust/crates/jni/docs/ |
| D | 0.21-MIGRATION.md | 7 … would cause undefined behavior. See [issue #392](https://github.com/jni-rs/jni-rs/issues/392) for…
14 ```rust
19 -> jstring {
31 ```rust
34 -> Result<()> {
45 When using `JNIEnv::with_local_frame`, `Executor::with_attached`, or `Executor::with_attached_capac…
47 ```rust
58 _Note: This also applies to `Executor::with_attached` and `Executor::with_attached_capacity` which …
71 ```rust
76 ```rust
[all …]
|
| /external/rust/crates/combine/ |
| D | Cargo.lock.saved | 6 name = "aho-corasick"
8 source = "registry+https://github.com/rust-lang/crates.io-index"
15 name = "async-channel"
17 source = "registry+https://github.com/rust-lang/crates.io-index"
20 "concurrent-queue",
21 "event-listener",
22 "futures-core",
26 name = "async-executor"
28 source = "registry+https://github.com/rust-lang/crates.io-index"
31 "async-task",
[all …]
|
| /external/rust/crates/num_cpus/ |
| D | TEST_MAPPING | 5 "path": "external/rust/crates/anyhow"
8 "path": "external/rust/crates/async-stream"
11 "path": "external/rust/crates/base64"
14 "path": "external/rust/crates/futures-channel"
17 "path": "external/rust/crates/futures-executor"
20 "path": "external/rust/crates/futures-test"
23 "path": "external/rust/crates/futures-util"
26 "path": "external/rust/crates/hashbrown"
29 "path": "external/rust/crates/ryu"
32 "path": "external/rust/crates/tinytemplate"
[all …]
|
| /external/rust/crates/futures-io/ |
| D | TEST_MAPPING | 5 "path": "external/rust/crates/anyhow"
8 "path": "external/rust/crates/async-stream"
11 "path": "external/rust/crates/futures-channel"
14 "path": "external/rust/crates/futures-executor"
17 "path": "external/rust/crates/futures-test"
20 "path": "external/rust/crates/futures-util"
23 "path": "external/rust/crates/tokio"
26 "path": "external/rust/crates/tokio-test"
|
| /external/rust/crates/futures-sink/ |
| D | TEST_MAPPING | 5 "path": "external/rust/crates/anyhow"
8 "path": "external/rust/crates/async-stream"
11 "path": "external/rust/crates/futures-channel"
14 "path": "external/rust/crates/futures-executor"
17 "path": "external/rust/crates/futures-test"
20 "path": "external/rust/crates/futures-util"
23 "path": "external/rust/crates/tokio"
26 "path": "external/rust/crates/tokio-test"
|
| /external/rust/crates/futures-core/ |
| D | TEST_MAPPING | 5 "path": "external/rust/crates/anyhow"
8 "path": "external/rust/crates/async-stream"
11 "path": "external/rust/crates/futures-channel"
14 "path": "external/rust/crates/futures-executor"
17 "path": "external/rust/crates/futures-test"
20 "path": "external/rust/crates/futures-util"
23 "path": "external/rust/crates/tokio"
26 "path": "external/rust/crates/tokio-test"
|
| /external/rust/crates/futures-macro/ |
| D | TEST_MAPPING | 5 "path": "external/rust/crates/anyhow"
8 "path": "external/rust/crates/async-stream"
11 "path": "external/rust/crates/futures-channel"
14 "path": "external/rust/crates/futures-executor"
17 "path": "external/rust/crates/futures-test"
20 "path": "external/rust/crates/futures-util"
23 "path": "external/rust/crates/tokio"
26 "path": "external/rust/crates/tokio-test"
|
| /external/rust/crates/futures-task/ |
| D | TEST_MAPPING | 5 "path": "external/rust/crates/anyhow"
8 "path": "external/rust/crates/async-stream"
11 "path": "external/rust/crates/futures-channel"
14 "path": "external/rust/crates/futures-executor"
17 "path": "external/rust/crates/futures-test"
20 "path": "external/rust/crates/futures-util"
23 "path": "external/rust/crates/tokio"
26 "path": "external/rust/crates/tokio-test"
49 "name": "futures-task_test_src_lib"
52 "presubmit-rust": [
[all …]
|
| /external/rust/crates/slab/ |
| D | TEST_MAPPING | 5 "path": "external/rust/crates/anyhow"
8 "path": "external/rust/crates/async-stream"
11 "path": "external/rust/crates/futures-channel"
14 "path": "external/rust/crates/futures-executor"
17 "path": "external/rust/crates/futures-test"
20 "path": "external/rust/crates/futures-util"
23 "path": "external/rust/crates/tokio"
26 "path": "external/rust/crates/tokio-test"
52 "presubmit-rust": [
|
| /external/rust/crates/futures-util/ |
| D | TEST_MAPPING | 5 "path": "external/rust/crates/anyhow"
8 "path": "external/rust/crates/async-stream"
11 "path": "external/rust/crates/futures-channel"
14 "path": "external/rust/crates/futures-executor"
17 "path": "external/rust/crates/futures-test"
20 "path": "external/rust/crates/tokio"
23 "path": "external/rust/crates/tokio-test"
46 "name": "futures-util_test_src_lib"
49 "presubmit-rust": [
51 "name": "futures-util_test_src_lib"
|
| /external/rust/crates/pin-project-lite/ |
| D | TEST_MAPPING | 5 "path": "external/rust/crates/anyhow"
8 "path": "external/rust/crates/async-stream"
11 "path": "external/rust/crates/futures-channel"
14 "path": "external/rust/crates/futures-executor"
17 "path": "external/rust/crates/futures-test"
20 "path": "external/rust/crates/futures-util"
23 "path": "external/rust/crates/tokio"
26 "path": "external/rust/crates/tokio-test"
|
| /external/rust/crates/futures-macro/src/ |
| D | lib.rs | 1 //! The futures-rs procedural macro implementations.
12 // Since https://github.com/rust-lang/cargo/pull/7700 `proc_macro` is part of the prelude for
13 // proc-macro crates, but to support older compilers we still need this explicit `extern crate`.
19 mod executor; module
26 pub fn join_internal(input: TokenStream) -> TokenStream { in join_internal()
32 pub fn try_join_internal(input: TokenStream) -> TokenStream { in try_join_internal()
38 pub fn select_internal(input: TokenStream) -> TokenStream { in select_internal()
44 pub fn select_biased_internal(input: TokenStream) -> TokenStream { in select_biased_internal()
48 // TODO: Change this to doc comment once rustdoc bug fixed: https://github.com/rust-lang/futures-rs…
51 pub fn test_internal(input: TokenStream, item: TokenStream) -> TokenStream { in test_internal()
[all …]
|