| /external/rust/crates/rayon-core/src/join/ |
| D | mod.rs | 95 A: FnOnce() -> RA + Send, in join()
96 B: FnOnce() -> RB + Send, in join()
97 RA: Send, in join()
98 RB: Send, in join()
117 A: FnOnce(FnContext) -> RA + Send, in join_context()
118 B: FnOnce(FnContext) -> RB + Send, in join_context()
119 RA: Send, in join_context()
120 RB: Send, in join_context()
183 err: Box<dyn Any + Send>, in join_recover_from_panic()
|
| /external/rust/crates/futures-util/src/sink/ |
| D | send.rs | 11 pub struct Send<'a, Si: ?Sized, Item> { struct
16 impl<Si: Unpin + ?Sized, Item> Unpin for Send<'_, Si, Item> {} implementation
18 impl<'a, Si: Sink<Item> + Unpin + ?Sized, Item> Send<'a, Si, Item> { implementation
26 impl<Si: Sink<Item> + Unpin + ?Sized, Item> Future for Send<'_, Si, Item> { implementation
|
| /external/rust/crates/rayon/src/iter/ |
| D | mod.rs | 367 OP: Fn(Self::Item) + Sync + Send, in for_each()
397 OP: Fn(&mut T, Self::Item) + Sync + Send, in for_each_with()
431 OP: Fn(&mut T, Self::Item) + Sync + Send, in for_each_init()
432 INIT: Fn() -> T + Sync + Send, in for_each_init()
459 OP: Fn(Self::Item) -> R + Sync + Send, in try_for_each()
498 OP: Fn(&mut T, Self::Item) -> R + Sync + Send, in try_for_each_with()
540 OP: Fn(&mut T, Self::Item) -> R + Sync + Send, in try_for_each_init()
541 INIT: Fn() -> T + Sync + Send, in try_for_each_init()
586 F: Fn(Self::Item) -> R + Sync + Send, in map()
587 R: Send, in map()
[all …]
|
| D | unzip.rs | 66 A: Send, in unzip()
67 B: Send, in unzip()
80 A: Send, in unzip_indexed()
81 B: Send, in unzip_indexed()
120 P: Fn(&I::Item) -> bool + Sync + Send, in partition()
160 P: Fn(I::Item) -> Either<L, R> + Sync + Send, in partition_map()
161 L: Send, in partition_map()
162 R: Send, in partition_map()
|
| /external/rust/crates/rayon-core/src/thread_pool/ |
| D | mod.rs | 107 OP: FnOnce() -> R + Send, in install()
108 R: Send, in install()
187 A: FnOnce() -> RA + Send, in join()
188 B: FnOnce() -> RB + Send, in join()
189 RA: Send, in join()
190 RB: Send, in join()
203 OP: FnOnce(&Scope<'scope>) -> R + Send, in scope()
204 R: Send, in scope()
218 OP: FnOnce(&ScopeFifo<'scope>) -> R + Send, in scope_fifo()
219 R: Send, in scope_fifo()
|
| /external/rust/crates/criterion/src/stats/univariate/ |
| D | mixed.rs | 19 T: Tuple + Send, in bootstrap()
20 T::Distributions: Send, in bootstrap()
21 T::Builder: Send, in bootstrap()
|
| D | mod.rs | 38 T: Tuple + Send, in bootstrap()
39 T::Distributions: Send, in bootstrap()
40 T::Builder: Send, in bootstrap()
|
| D | sample.rs | 205 T: Tuple + Send, in bootstrap()
206 T::Distributions: Send, in bootstrap()
207 T::Builder: Send, in bootstrap()
|
| /external/flatbuffers/tests/MyGame/Example/ |
| D | MonsterStorage_grpc.go | 76 Send(*flatbuffers.Builder) error methodSpec
85 func (x *monsterStorageGetMaxHitPointClient) Send(m *flatbuffers.Builder) error { func
105 Send(*flatbuffers.Builder) error methodSpec
114 func (x *monsterStorageGetMinMaxHitPointsClient) Send(m *flatbuffers.Builder) error { func
160 Send(* flatbuffers.Builder) error methodSpec
168 func (x *monsterStorageRetrieveServer) Send(m *flatbuffers.Builder) error { func
203 Send(* flatbuffers.Builder) error methodSpec
212 func (x *monsterStorageGetMinMaxHitPointsServer) Send(m *flatbuffers.Builder) error { func
|
| /external/crosvm/devices/src/ |
| D | serial_device.rs | 16 input: Option<Box<dyn io::Read + Send>>, in new()
17 output: Option<Box<dyn io::Write + Send>>, in new()
|
| /external/rust/crates/rayon/src/iter/collect/ |
| D | mod.rs | 17 T: Send, in collect_into_vec()
38 T: Send, in special_extend()
49 A: Send, in unzip_into_vecs()
50 B: Send, in unzip_into_vecs()
|
| /external/rust/crates/rayon-core/tests/ |
| D | scope_join.rs | 4 F: FnOnce() + Send, in pseudo_join()
5 G: FnOnce() + Send, in pseudo_join()
|
| /external/rust/crates/async-stream/src/ |
| D | yielder.rs | 42 struct Send<T> { struct
46 impl<T: Unpin> Future for Send<T> { argument
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | sendrecv_ops_test.cc | 30 Status Send(const ParsedKey& key, const Args& args, const Tensor& val, in Send() function in tensorflow::__anona1b221550111::DummyRendezvous
42 static Graph* Send() { in Send() function
|
| /external/rust/crates/criterion/src/stats/bivariate/ |
| D | mod.rs | 71 T: Tuple + Send, in bootstrap()
72 T::Distributions: Send, in bootstrap()
73 T::Builder: Send, in bootstrap()
|
| /external/rust/crates/rayon-core/src/scope/ |
| D | mod.rs | 288 OP: FnOnce(&Scope<'scope>) -> R + Send, in scope()
289 R: Send, in scope()
379 OP: FnOnce(&ScopeFifo<'scope>) -> R + Send, in scope_fifo()
380 R: Send, in scope_fifo()
|
| /external/rust/crates/rayon-core/src/ |
| D | registry.rs | 326 pub(super) fn handle_panic(&self, err: Box<dyn Any + Send>) { in handle_panic()
436 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker()
437 R: Send, in in_worker()
457 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker_cold()
458 R: Send, in in_worker_cold()
486 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker_cross()
487 R: Send, in in_worker_cross()
870 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker()
871 R: Send, in in_worker()
|
| D | unwind.rs | 20 pub(super) fn resume_unwinding(payload: Box<dyn Any + Send>) -> ! { in resume_unwinding()
|
| /external/golang-protobuf/protoc-gen-go/testdata/grpc/ |
| D | grpc.pb.go | 262 Send(*StreamMsg) error methodSpec
271 func (x *testUpstreamClient) Send(m *StreamMsg) error { func
296 Send(*StreamMsg) error methodSpec
305 func (x *testBidiClient) Send(m *StreamMsg) error { func
376 Send(*StreamMsg) error methodSpec
384 func (x *testDownstreamServer) Send(m *StreamMsg) error { func
419 Send(*StreamMsg2) error methodSpec
428 func (x *testBidiServer) Send(m *StreamMsg2) error { func
|
| /external/rust/crates/anyhow/tests/ |
| D | test_autotrait.rs | 5 fn assert_send<T: Send>() {} in test_send()
|
| /external/libbrillo/brillo/dbus/ |
| D | dbus_signal.h | 56 bool Send(const Args&... args) const { in Send() function
|
| /external/rust/cxx/tests/ |
| D | cxx_string.rs | 13 fn assert_send(_: impl Send) {} in test_async_cxx_string()
|
| /external/webrtc/p2p/base/ |
| D | stun_server_unittest.cc | 45 void Send(const StunMessage& msg) { in Send() function in cricket::StunServerTest
50 void Send(const char* buf, int len) { in Send() function in cricket::StunServerTest
|
| /external/rust/crates/tokio/src/time/tests/ |
| D | mod.rs | 6 fn assert_send<T: Send>() {} in assert_send()
|
| /external/rust/cxx/tests/ui/ |
| D | opaque_autotraits.rs | 8 fn assert_send<T: Send>() {} in assert_send()
|