Searched refs:map_ok (Results 1 – 14 of 14) sorted by relevance
| /external/rust/crates/futures/tests/ |
| 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()
67 run(future::try_join(future::try_join(p1, p2), p3).map_ok(move |v| tx.send(v).unwrap())); in join5()
83 run(future::try_select(p1, p2).map_ok(move |v| tx.send(v).unwrap())); in select1()
91 run(p2.map_ok(move |v| tx.send(v).unwrap())); in select1()
110 run(p2.map_ok(move |v| tx.send(v).unwrap())); in select2()
151 run(future::try_select(p1, p2).map_ok(move |_| tx3.send(()).unwrap())); in select4()
|
| D | oneshot.rs | 13 rx1.map_ok(move |x| tx2.send(x)).run_in_background(); in oneshot_send1()
30 rx1.map_ok(move |x| tx2.send(x).unwrap()).run_in_background(); in oneshot_send2()
45 rx1.map_ok(move |x| tx2.send(x).unwrap()).run_in_background(); in oneshot_send3()
|
| D | basic_combinators.rs | 54 .map_ok(move |x: i32| { in basic_try_future_combinators()
79 .map_ok(move |x: i32| { in basic_try_future_combinators()
|
| D | eager_drop.rs | 2 fn map_ok() { in map_ok() function
13 .map_ok(move |_| { let _tx1 = tx1; panic!("should not run"); }) in map_ok()
|
| D | shared.rs | 75 let _ = block_on(f2.map_ok(|x| tx3.send(x).unwrap()).map_err(|_| ())); in drop_on_one_task_ok()
|
| D | sink.rs | 371 .map_ok(move |()| elem + 1) in with_flush()
|
| /external/rust/crates/itertools/tests/ |
| D | specializations.rs | 97 fn map_ok(v: Vec<Result<u8, char>>) -> () {
98 test_specializations(&v.into_iter().map_ok(|u| u.checked_add(1)));
|
| /external/rust/crates/tokio/src/net/unix/ |
| D | stream.rs | 204 self.io.registration().poll_read_ready(cx).map_ok(|_| ()) in poll_read_ready()
431 self.io.registration().poll_write_ready(cx).map_ok(|_| ()) in poll_write_ready()
|
| /external/rust/crates/tokio/src/net/tcp/ |
| D | stream.rs | 496 self.io.registration().poll_read_ready(cx).map_ok(|_| ()) in poll_read_ready()
719 self.io.registration().poll_write_ready(cx).map_ok(|_| ()) in poll_write_ready()
|
| /external/rust/crates/itertools/src/adaptors/ |
| D | map.rs | 88 pub fn map_ok<I, F, T, U, E>(iter: I, f: F) -> MapOk<I, F> in map_ok() function
|
| D | mod.rs | 11 pub use self::map::{map_into, map_ok, MapInto, MapOk};
|
| /external/rust/crates/futures-util/src/future/try_future/ |
| D | mod.rs | 217 fn map_ok<T, F>(self, f: F) -> MapOk<Self, F> in map_ok() method
|
| /external/rust/crates/itertools/src/ |
| D | lib.rs | 778 self.map_ok(f) in map_results()
792 fn map_ok<F, T, U, E>(self, f: F) -> MapOk<Self, F> in map_ok() method
796 adaptors::map_ok(self, f) in map_ok()
|
| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | mod.rs | 187 fn map_ok<T, F>(self, f: F) -> MapOk<Self, F> in map_ok() method
|