| /external/rust/crates/tokio/tests/ |
| D | macros_try_join.rs | 7 let foo = tokio::try_join!(async { ok(1) },); in sync_one_lit_expr_comma()
14 let foo = tokio::try_join!(async { ok(1) }); in sync_one_lit_expr_no_comma()
21 let foo = tokio::try_join!(async { ok(1) }, async { ok(2) },); in sync_two_lit_expr_comma()
28 let foo = tokio::try_join!(async { ok(1) }, async { ok(2) }); in sync_two_lit_expr_no_comma()
39 task::spawn(async { tokio::try_join!(async { rx1.await }, async { rx2.await }) }); in two_await()
61 tokio::try_join!(async { rx1.await }, async { rx2.await }, async { in err_abort_early()
87 tokio::try_join!(ready) in join_size()
94 tokio::try_join!(ready1, ready2) in join_size()
|
| D | tcp_into_split.rs | 10 use tokio::try_join;
19 let (stream1, (mut stream2, _)) = try_join! { in split()
25 let ((), (), ()) = try_join! { in split()
|
| D | uds_stream.rs | 12 use futures::future::{poll_fn, try_join};
26 let ((mut server, _), mut client) = try_join(accept, connect).await?; in accept_read_write()
53 let ((mut server, _), mut client) = try_join(accept, connect).await?; in shutdown()
154 let ((server, _), client) = assert_ok!(try_join(accept, connect).await); in create_pair()
|
| D | uds_split.rs | 20 let (a_response, b_response) = futures::future::try_join( in split()
|
| D | tcp_stream.rs | 6 use tokio::try_join;
208 let (client, (server, _)) = assert_ok!(try_join!(TcpStream::connect(&addr), listener.accept())); in create_pair()
|
| D | uds_datagram.rs | 8 use tokio::try_join;
127 let ((), ()) = try_join! { in split()
|
| /external/rust/crates/futures-util/src/async_await/ |
| D | join_mod.rs | 6 ($join:item $try_join:item) => {
80 $try_join
104 macro_rules! try_join {
|
| /external/rust/crates/futures/tests/ |
| D | try_join.rs | 3 use futures::{try_join, executor::block_on};
23 try_join!(future1, future2) in try_join_never_error()
33 try_join!(future1, future2) in try_join_never_ok()
|
| D | macro_comma_support.rs | 44 fn try_join() { in try_join() function
48 try_join, in try_join()
54 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()
26 run(future::try_join(p1, p2).map_ok(move |v| tx.send(v).unwrap())); in join2()
40 run(future::try_join(p1, p2).map_err(move |_v| tx.send(1).unwrap())); in join3()
53 run(future::try_join(p1, p2).map_err(move |v| tx.send(v).unwrap())); in join4()
67 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 | 396 use futures::try_join; in try_join_size()
401 try_join!(ready) in try_join_size()
408 try_join!(ready1, ready2) in try_join_size()
424 use futures::try_join; in try_join_doesnt_require_unpin()
427 try_join!( in try_join_doesnt_require_unpin()
|
| /external/rust/crates/tokio/src/macros/ |
| D | try_join.rs | 64 macro_rules! try_join { macro
124 $crate::try_join!(@{ ($($s)* _) $($t)* ($($s)*) $e, } $($r)*)
130 $crate::try_join!(@{ () } $($e,)*)
|
| D | mod.rs | 30 mod try_join;
|
| /external/rust/crates/tokio/src/future/ |
| D | mod.rs | 17 mod try_join;
18 pub(crate) use try_join::try_join3;
|
| /external/rust/crates/futures-util/src/future/ |
| D | mod.rs | 90 mod try_join; module
91 pub use self::try_join::{
92 try_join, try_join3, try_join4, try_join5, TryJoin, TryJoin3, TryJoin4, TryJoin5,
|
| D | try_join.rs | 148 pub fn try_join<Fut1, Fut2>(future1: Fut1, future2: Fut2) -> TryJoin<Fut1, Fut2> in try_join() function
|
| /external/rust/crates/futures-macro/src/ |
| D | lib.rs | 30 crate::join::try_join(input) in try_join_internal()
|
| D | join.rs | 91 pub(crate) fn try_join(input: TokenStream) -> TokenStream { in try_join() function
|
| /external/rust/crates/futures/src/ |
| D | lib.rs | 132 pub use futures_util::{join, pending, poll, select_biased, try_join}; // Async-await
|
| /external/rust/crates/tokio/ |
| D | CHANGELOG.md | 861 - macros: `try_join!` waits for all branches to complete or the first error ([#2169]).
|