| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | macros_try_join.rs | 17 let foo = tokio::try_join!(async { ok(1) },); in sync_one_lit_expr_comma()
24 let foo = tokio::try_join!(async { ok(1) }); in sync_one_lit_expr_no_comma()
31 let foo = tokio::try_join!(async { ok(1) }, async { ok(2) },); in sync_two_lit_expr_comma()
38 let foo = tokio::try_join!(async { ok(1) }, async { ok(2) }); in sync_two_lit_expr_no_comma()
48 let mut join = task::spawn(async { tokio::try_join!(rx1, rx2) }); in two_await()
69 let mut join = task::spawn(async { tokio::try_join!(rx1, rx2, rx3) }); in err_abort_early()
93 tokio::try_join!(ready) in join_size()
100 tokio::try_join!(ready1, ready2) in join_size()
141 let result = tokio::try_join!( in try_join_does_not_allow_tasks_to_starve()
184 assert_eq!(tokio::try_join!() as Result<_, ()>, Ok(())); in empty_try_join()
|
| D | tcp_into_split.rs | 11 use tokio::try_join;
20 let (stream1, (mut stream2, _)) = try_join! { in split()
26 let ((), (), ()) = try_join! { in split()
|
| D | uds_stream.rs | 17 use futures::future::{poll_fn, try_join};
31 let ((mut server, _), mut client) = try_join(accept, connect).await?; in accept_read_write()
58 let ((mut server, _), mut client) = try_join(accept, connect).await?; in shutdown()
204 let ((server, _), client) = assert_ok!(try_join(accept, connect).await); in create_pair()
439 let ((stream, _), _) = try_join(accept, connect).await.unwrap(); in abstract_socket_name()
|
| D | uds_socket.rs | 5 use futures::future::try_join;
74 let ((mut server, _), mut client) = try_join(accept, connect).await?; in listen_and_stream()
|
| D | uds_split.rs | 21 let (a_response, b_response) = futures::future::try_join( in split()
|
| D | tcp_stream.rs | 6 use tokio::try_join;
256 let (client, (server, _)) = assert_ok!(try_join!(TcpStream::connect(&addr), listener.accept())); in create_pair()
|
| /external/rust/android-crates-io/crates/tokio/src/macros/ |
| D | try_join.rs | 2 ($try_join:item) => {
105 $try_join
110 doc! {macro_rules! try_join {
115 doc! {macro_rules! try_join {
220 $crate::try_join!(@{ ($($s)* _) ($($n)* + 1) $($t)* ($($s)*) $e, } $($r)*)
226 $crate::try_join!(@{ () (0) } $($e,)*)
|
| D | mod.rs | 31 mod try_join;
|
| /external/rust/android-crates-io/crates/futures-util/src/async_await/ |
| D | join_mod.rs | 4 ($join:item $try_join:item) => {
78 $try_join
102 macro_rules! try_join {
|
| /external/rust/android-crates-io/crates/futures/tests/ |
| D | try_join.rs | 3 use futures::{executor::block_on, try_join};
22 try_join!(future1, future2) in try_join_never_error()
32 try_join!(future1, future2) in try_join_never_ok()
|
| D | macro_comma_support.rs | 6 try_join,
36 fn try_join() { in try_join() function
40 try_join!(future1, future2,) in try_join()
|
| D | eventual.rs | 16 run(future::try_join(ok::<i32, i32>(1), ok(2)).map_ok(move |v| tx.send(v).unwrap())); in join1()
28 run(future::try_join(p1, p2).map_ok(move |v| tx.send(v).unwrap())); in join2()
44 run(future::try_join(p1, p2).map_err(move |_v| tx.send(1).unwrap())); in join3()
59 run(future::try_join(p1, p2).map_err(move |v| tx.send(v).unwrap())); in join4()
75 run(future::try_join(future::try_join(p1, p2), p3).map_ok(move |v| tx.send(v).unwrap())); in join5()
|
| D | async_await_macros.rs | 8 join, pending, pin_mut, poll, select, select_biased, stream, stream_select, try_join,
383 try_join!(ready) in try_join_size()
390 try_join!(ready1, ready2) in try_join_size()
404 let _ = async { try_join!(async { Ok::<(), ()>(()) }, async { Ok::<(), ()>(()) },) }; in try_join_doesnt_require_unpin()
|
| /external/rust/android-crates-io/crates/tokio/src/future/ |
| D | mod.rs | 9 mod try_join;
10 pub(crate) use try_join::try_join3;
|
| /external/rust/android-crates-io/crates/futures-util/src/future/ |
| D | mod.rs | 96 mod try_join; module
97 pub use self::try_join::{
98 try_join, try_join3, try_join4, try_join5, TryJoin, TryJoin3, TryJoin4, TryJoin5,
|
| /external/rust/pica/src/bin/ |
| D | main.rs | 23 use tokio::try_join;
84 try_join!(accept_incoming(commands.clone(), args.uci_port), pica.run(),)?; in main()
|
| /external/rust/android-crates-io/crates/tokio-util/tests/ |
| D | udp.rs | 11 use futures::future::try_join;
44 let (_, received) = try_join(send, recv).await.unwrap(); in send_framed_byte_codec()
70 let (_, received) = try_join(send, recv).await.unwrap(); in send_framed_byte_codec()
|
| /external/bazelbuild-rules_rust/examples/bzlmod/proto_with_toolchain/grpc_server/src/ |
| D | main.rs | 31 match tokio::try_join!(grpc_handle) { in main()
|
| /external/bazelbuild-rules_rust/examples/bzlmod/proto/grpc_server/src/ |
| D | main.rs | 31 match tokio::try_join!(grpc_handle) { in main()
|
| /external/rust/android-crates-io/crates/futures-macro/src/ |
| D | lib.rs | 27 crate::join::try_join(input) in try_join_internal()
|
| D | join.rs | 89 pub(crate) fn try_join(input: TokenStream) -> TokenStream { in try_join() function
|
| /external/crosvm/base/src/sys/windows/ |
| D | thread.rs | 43 pub fn try_join(self, timeout: Duration) -> Result<T, JoinError> { in try_join() method
|
| /external/rust/android-crates-io/crates/shlex/src/ |
| D | lib.rs | 213 pub fn try_join<'a, I: IntoIterator<Item = &'a str>>(words: I) -> Result<String, QuoteError> { in try_join() function
356 assert_eq!(try_join(vec!["\0"]), Err(QuoteError::Nul)); in test_fallible()
|
| /external/rust/android-crates-io/crates/futures/src/ |
| D | lib.rs | 127 pub use futures_util::{join, pending, poll, select_biased, try_join}; // Async-await
|
| /external/rust/android-crates-io/crates/futures/ |
| D | Cargo.toml | 283 name = "try_join"
284 path = "tests/try_join.rs"
|