| /external/rust/crates/num-traits/src/ |
| D | cast.rs | 24 self.to_i64().as_ref().and_then(ToPrimitive::to_isize) in to_isize()
31 self.to_i64().as_ref().and_then(ToPrimitive::to_i8) in to_i8()
38 self.to_i64().as_ref().and_then(ToPrimitive::to_i16) in to_i16()
45 self.to_i64().as_ref().and_then(ToPrimitive::to_i32) in to_i32()
70 self.to_u64().as_ref().and_then(ToPrimitive::to_usize) in to_usize()
77 self.to_u64().as_ref().and_then(ToPrimitive::to_u8) in to_u8()
84 self.to_u64().as_ref().and_then(ToPrimitive::to_u16) in to_u16()
91 self.to_u64().as_ref().and_then(ToPrimitive::to_u32) in to_u32()
117 self.to_f64().as_ref().and_then(ToPrimitive::to_f32) in to_f32()
131 None => self.to_u64().as_ref().and_then(ToPrimitive::to_f64), in to_f64()
[all …]
|
| /external/rust/crates/nix/test/ |
| D | test_mount.rs | 67 .and_then(|mut f| f.write(SCRIPT_CONTENTS)) in test_mount_tmpfs_without_flags_allows_rwx()
73 .and_then(|mut f| f.read_to_end(&mut buf)) in test_mount_tmpfs_without_flags_allows_rwx()
122 .and_then(|mut f| f.write(SCRIPT_CONTENTS)) in test_mount_noexec_disallows_exec()
162 .and_then(|mut f| f.write(SCRIPT_CONTENTS)) in test_mount_bind()
173 .and_then(|mut f| f.read_to_end(&mut buf)) in test_mount_bind()
198 .and_then(|mut f| f.write(format!("1000 {} 1\n", uid).as_bytes())) in setup_namespaces()
|
| /external/rust/crates/futures/tests_disabled/ |
| D | stream.rs | 40 .and_then(|tx| tx.send(Ok(2))) in list()
41 .and_then(|tx| tx.send(Ok(3))) in list()
49 .and_then(|tx| tx.send(Ok(2))) in err_list()
50 .and_then(|tx| tx.send(Err(3))) in err_list()
102 fn and_then() { in and_then() function
103 assert_done(|| list().and_then(|a| Ok(a + 1)).collect(), Ok(vec![2, 3, 4])); in and_then()
104 assert_done(|| list().and_then(|a| err::<i32, u32>(a as u32)).collect::<Vec<_>>(), in and_then()
197 .and_then(|tx| tx.send(Box::new(d.map_err(|_| panic!())))) in buffered()
215 .and_then(|tx| tx.send(Box::new(d.map_err(|_| panic!())))) in buffered()
236 .and_then(|tx| tx.send(Box::new(d.recover(|_| panic!())))) in unordered()
[all …]
|
| D | all.rs | 28 is_future_v::<i32, u32, _>(f_ok(1).and_then(Ok)); in result_smoke()
43 assert_done(|| f_ok(1).and_then(|a| Ok(a + 2)), r_ok(3)); in result_smoke()
44 assert_done(|| f_err(1).and_then(|a| Ok(a + 2)), r_err(1)); in result_smoke()
45 assert_done(|| f_ok(1).and_then(|a| Err(a as u32 + 3)), r_err(4)); in result_smoke()
46 assert_done(|| f_err(1).and_then(|a| Err(a as u32 + 4)), r_err(1)); in result_smoke()
75 assert_empty(|| empty().and_then(move |_| empty())); in test_empty()
77 assert_empty(|| f_ok(1).and_then(move |_| empty())); in test_empty()
257 .and_then(|either_tup| { in select2()
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | hpack_parser.cc | 784 static const grpc_chttp2_hpack_parser_state and_then[] = { in parse_indexed_field_x() local
787 p->next_state = and_then; in parse_indexed_field_x()
826 static const grpc_chttp2_hpack_parser_state and_then[] = { in parse_lithdr_incidx() local
829 p->next_state = and_then; in parse_lithdr_incidx()
838 static const grpc_chttp2_hpack_parser_state and_then[] = { in parse_lithdr_incidx_x() local
842 p->next_state = and_then; in parse_lithdr_incidx_x()
852 static const grpc_chttp2_hpack_parser_state and_then[] = { in parse_lithdr_incidx_v() local
856 p->next_state = and_then; in parse_lithdr_incidx_v()
893 static const grpc_chttp2_hpack_parser_state and_then[] = { in parse_lithdr_notidx() local
896 p->next_state = and_then; in parse_lithdr_notidx()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
| D | hpack_parser.cc | 801 static const grpc_chttp2_hpack_parser_state and_then[] = { in parse_indexed_field_x() local
804 p->next_state = and_then; in parse_indexed_field_x()
860 static const grpc_chttp2_hpack_parser_state and_then[] = { in parse_lithdr_incidx() local
863 p->next_state = and_then; in parse_lithdr_incidx()
873 static const grpc_chttp2_hpack_parser_state and_then[] = { in parse_lithdr_incidx_x() local
877 p->next_state = and_then; in parse_lithdr_incidx_x()
888 static const grpc_chttp2_hpack_parser_state and_then[] = { in parse_lithdr_incidx_v() local
892 p->next_state = and_then; in parse_lithdr_incidx_v()
924 static const grpc_chttp2_hpack_parser_state and_then[] = { in parse_lithdr_notidx() local
927 p->next_state = and_then; in parse_lithdr_notidx()
[all …]
|
| /external/rust/crates/itertools/src/ |
| D | size_hint.rs | 28 hi = hi.and_then(|elt| elt.checked_add(x)); in add_scalar()
74 hi = hi.and_then(|elt| elt.checked_mul(x)); in mul_scalar()
84 let hi = exp.1.and_then(|exp| { in pow_scalar_base()
|
| /external/rust/crates/bindgen/src/ir/ |
| D | enum_ty.rs | 68 .and_then(|et| Item::from_ty(&et, declaration, None, ctx).ok()); in from_ty()
72 repr.and_then(|r| ctx.resolve_type(r).safe_canonical_type(ctx)); in from_ty()
106 .and_then(|callbacks| { in from_ty()
123 .and_then(|callbacks| { in from_ty()
|
| D | var.rs | 283 .and_then(|c| c.int_macro(&name, value)) in parse()
334 .and_then(|t| t.safe_canonical_type(ctx)); in parse()
349 let mut val = cursor.evaluate().and_then(|v| v.as_int()); in parse()
365 .and_then(|v| v.as_double()) in parse()
370 .and_then(|v| v.as_literal_string()) in parse()
|
| /external/rust/crates/cexpr/tests/ |
| D | clang.rs | 33 .and_then(|v| i64::from_str(&v).ok()) in test_definition()
81 .and_then(|v| f64::from_str(&v).ok()) in test_definition()
86 .and_then(|v| u64::from_str(v).ok()) in test_definition()
92 .and_then(|v| u32::from_str(v).ok()) in test_definition()
93 .and_then(char::from_u32) in test_definition()
|
| /external/rust/crates/rusqlite/src/types/ |
| D | from_sql.rs | 95 i64::column_result(value).and_then(|i| { in column_result()
109 i64::column_result(value).and_then(|i| {
185 value.as_blob().and_then(|bytes| { in column_result()
200 .and_then(|bytes| { in column_result()
|
| /external/rust/crates/cexpr/src/ |
| D | literal.rs | 167 .and_then(|i| u64::from_str_radix(i, radix).ok()) in c_raw_escape()
177 .and_then(|i| u32::from_str_radix(i, 16).ok()) in c_unicode_escape()
178 .and_then(char::from_u32) in c_unicode_escape()
244 .and_then(|i| u64::from_str_radix(i, radix).ok()) in c_int_radix()
337 |v| str::from_utf8(v).ok().and_then(|i| f64::from_str(i).ok()), in c_float()
|
| /external/crosvm/gpu_display/src/ |
| D | gpu_display_stub.rs | 117 SurfaceId::new(surface_id).and_then(move |id| self.surfaces.get_mut(&id)) in get_surface()
121 SurfaceId::new(surface_id).and_then(|id| self.surfaces.remove(&id)); in destroy_surface()
170 .and_then(|s| s.framebuffer()) in framebuffer()
|
| D | gpu_display_x.rs | 515 .and_then(|b| Some(b.as_ref()?.in_use)) in next_buffer_in_use()
632 ObjectId::new(surface_id).and_then(move |id| self.surfaces.get(&id)) in surface_ref()
636 ObjectId::new(surface_id).and_then(move |id| self.surfaces.get_mut(&id)) in surface_mut()
640 ObjectId::new(event_device_id).and_then(move |id| self.event_devices.get(&id)) in event_device()
644 ObjectId::new(event_device_id).and_then(move |id| self.event_devices.get_mut(&id)) in event_device_mut()
743 ObjectId::new(surface_id).and_then(|id| self.surfaces.remove(&id)) in release_surface()
750 self.surface_mut(surface_id).and_then(|s| s.framebuffer()) in framebuffer()
820 ObjectId::new(event_device_id).and_then(|id| self.event_devices.remove(&id)); in release_event_device()
|
| /external/rust/crates/mio/src/sys/unix/ |
| D | net.rs | 33 let socket = socket.and_then(|socket| { in new_socket()
47 let socket = socket.and_then(|socket| { in new_socket()
51 .and_then(|_| syscall!(fcntl(socket, libc::F_SETFD, libc::FD_CLOEXEC)).map(|_| socket)) in new_socket()
|
| /external/rust/crates/which/src/ |
| D | lib.rs | 55 which_all(binary_name).and_then(|mut i| i.next().ok_or(Error::CannotFindBinaryPath)) in which()
73 .and_then(|mut i| i.next().ok_or(Error::CannotFindBinaryPath)) in which_in()
231 .and_then(|p| p.canonicalize().map_err(|_| Error::CannotCanonicalize)) in new()
262 .and_then(|p| p.canonicalize().map_err(|_| Error::CannotCanonicalize)) in new_in()
|
| /external/crosvm/base/src/ |
| D | shm.rs | 24 .and_then(|mut shm| shm.set_size(size).map(|_| shm)) in named()
34 .and_then(|mut shm| shm.set_size(size).map(|_| shm)) in new()
|
| /external/rust/crates/csv/src/ |
| D | deserializer.rs | 165 Ok(self.headers.as_mut().and_then(|it| it.next())) in next_header()
263 Ok(self.headers.as_mut().and_then(|it| it.next())) in next_header_bytes()
268 self.next_field_bytes().and_then(|field| { in next_field()
427 self.next_field().and_then(|f| visitor.visit_borrowed_str(f)) in deserialize_str()
434 self.next_field().and_then(|f| visitor.visit_str(f.into())) in deserialize_string()
441 self.next_field_bytes().and_then(|f| visitor.visit_borrowed_bytes(f)) in deserialize_bytes()
449 .and_then(|f| visitor.visit_byte_buf(f.to_vec())) in deserialize_byte_buf()
779 str::from_utf8(s).ok().and_then(|s| s.parse().ok()) in try_positive_integer64_bytes()
783 str::from_utf8(s).ok().and_then(|s| s.parse().ok()) in try_negative_integer64_bytes()
788 str::from_utf8(s).ok().and_then(|s| s.parse().ok())
[all …]
|
| /external/rust/crates/clang-sys/src/ |
| D | support.rs | 189 let major = try_opt!(numbers.next().and_then(parse_version_number)); in parse_version()
190 let minor = try_opt!(numbers.next().and_then(parse_version_number)); in parse_version()
191 let subminor = numbers.next().and_then(parse_version_number).unwrap_or(0); in parse_version()
|
| /external/rust/crates/chrono/src/ |
| D | date.rs | 92 NaiveTime::from_hms_opt(hour, min, sec).and_then(|time| self.and_time(time)) in and_hms_opt()
118 NaiveTime::from_hms_milli_opt(hour, min, sec, milli).and_then(|time| self.and_time(time)) in and_hms_milli_opt()
144 NaiveTime::from_hms_micro_opt(hour, min, sec, micro).and_then(|time| self.and_time(time)) in and_hms_micro_opt()
170 NaiveTime::from_hms_nano_opt(hour, min, sec, nano).and_then(|time| self.and_time(time)) in and_hms_nano_opt()
274 f(d.naive_local()).and_then(|date| d.timezone().from_local_date(&date).single()) in map_local()
|
| /external/rust/crates/mio/src/sys/unix/uds/ |
| D | listener.rs | 15 .and_then(|_| syscall!(listen(socket, 1024))) in bind()
79 .and_then(|socket| { in accept()
|
| /external/crosvm/devices/src/utils/ |
| D | event_loop.rs | 61 .and_then(|e| Ok((e.try_clone()?, e))) in start()
67 .and_then(|pc| { in start()
222 let (self_evt, evt) = match Event::new().and_then(|e| Ok((e.try_clone()?, e))) { in event_loop_test()
|
| /external/rust/crates/arbitrary/src/ |
| D | size_hint.rs | 28 let upper = lhs.1.and_then(|lhs| rhs.1.map(|rhs| lhs + rhs)); in and()
48 .and_then(|lhs| rhs.1.map(|rhs| std::cmp::max(lhs, rhs))); in or()
|
| /external/rust/crates/structopt-derive/src/ |
| D | ty.rs | 70 .and_then(|segment| { in subty_if()
72 only_one(args.args.iter()).and_then(|genneric| { in subty_if()
|
| /external/crosvm/sys_util/src/linux/ |
| D | syslog.rs | 87 .and_then(|()| { in log()
94 .and_then(|()| write!(&mut buf_cursor, "{}", args)) in log()
|