| /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()
28 run(future::try_join(p1, p2).map_ok(move |v| tx.send(v).unwrap())); in join2()
75 run(future::try_join(future::try_join(p1, p2), p3).map_ok(move |v| tx.send(v).unwrap())); in join5()
93 run(future::try_select(p1, p2).map_ok(move |v| tx.send(v).unwrap())); in select1()
101 run(p2.map_ok(move |v| tx.send(v).unwrap())); in select1()
122 run(p2.map_ok(move |v| tx.send(v).unwrap())); in select2()
169 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()
24 rx1.map_ok(move |x| tx2.send(x).unwrap()).run_in_background(); in oneshot_send2()
33 rx1.map_ok(move |x| tx2.send(x).unwrap()).run_in_background(); in oneshot_send3()
|
| D | future_basic_combinators.rs | 58 .map_ok(move |x: i32| { in basic_try_future_combinators()
83 .map_ok(move |x: i32| { in basic_try_future_combinators()
|
| D | eager_drop.rs | 10 fn map_ok() { in map_ok() function
17 .map_ok(move |_| { in map_ok()
|
| D | future_shared.rs | 71 let _ = block_on(f2.map_ok(|x| tx3.send(x).unwrap()).map_err(|_| ())); in drop_on_one_task_ok()
|
| D | sink.rs | 297 .map_ok(move |()| elem + 1) in with_flush()
|
| /external/rust/crates/itertools/tests/ |
| D | specializations.rs | 103 fn map_ok(v: Vec<Result<u8, char>>) -> () {
104 test_specializations(&v.into_iter().map_ok(|u| u.checked_add(1)));
|
| /external/rust/crates/tokio/src/net/windows/ |
| D | named_pipe.rs | 387 self.io.registration().poll_read_ready(cx).map_ok(|_| ()) in poll_read_ready()
694 self.io.registration().poll_write_ready(cx).map_ok(|_| ()) in poll_write_ready()
1142 self.io.registration().poll_read_ready(cx).map_ok(|_| ()) in poll_read_ready()
1446 self.io.registration().poll_write_ready(cx).map_ok(|_| ()) in poll_write_ready()
|
| /external/rust/crates/tokio/src/net/unix/ |
| D | stream.rs | 230 self.io.registration().poll_read_ready(cx).map_ok(|_| ()) in poll_read_ready()
546 self.io.registration().poll_write_ready(cx).map_ok(|_| ()) in poll_write_ready()
|
| /external/rust/crates/tokio/src/net/unix/datagram/ |
| D | socket.rs | 261 self.io.registration().poll_write_ready(cx).map_ok(|_| ()) in poll_send_ready()
357 self.io.registration().poll_read_ready(cx).map_ok(|_| ()) in poll_recv_ready()
|
| /external/rust/crates/tokio/src/net/tcp/ |
| D | stream.rs | 544 self.io.registration().poll_read_ready(cx).map_ok(|_| ()) in poll_read_ready()
856 self.io.registration().poll_write_ready(cx).map_ok(|_| ()) in poll_write_ready()
|
| /external/rust/crates/itertools/src/adaptors/ |
| D | map.rs | 92 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/tokio/src/net/ |
| D | udp.rs | 517 self.io.registration().poll_write_ready(cx).map_ok(|_| ()) in poll_send_ready()
737 self.io.registration().poll_read_ready(cx).map_ok(|_| ()) in poll_recv_ready()
|
| /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 | 848 self.map_ok(f) in map_results()
862 fn map_ok<F, T, U, E>(self, f: F) -> MapOk<Self, F> in map_ok() method
866 adaptors::map_ok(self, f) in map_ok()
|
| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | mod.rs | 200 fn map_ok<T, F>(self, f: F) -> MapOk<Self, F> in map_ok() method
|
| /external/rust/crates/combine/tests/ |
| D | async.rs | 216 .map_ok(|x| { in run_decoder()
|
| /external/rust/crates/itertools/ |
| D | CHANGELOG.md | 58 - Deprecate `Itertools::map_results`, use `Itertools::map_ok` instead (#377)
|