| /external/rust/crates/mio/src/sys/unix/ |
| D | pipe.rs | 377 pub struct Receiver { struct
381 impl Receiver { implementation
456 impl event::Source for Receiver { implementation
480 impl Read for Receiver { implementation
490 impl Read for &Receiver { implementation
503 impl From<ChildStdout> for Receiver { implementation
504 fn from(stdout: ChildStdout) -> Receiver { in from()
513 impl From<ChildStderr> for Receiver { implementation
514 fn from(stderr: ChildStderr) -> Receiver { in from()
520 impl FromRawFd for Receiver { implementation
[all …]
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | shutdown.rs | 17 pub(super) struct Receiver { struct
18 rx: oneshot::Receiver<()>, argument
29 impl Receiver { impl
|
| /external/rust/crates/darling/tests/compile-fail/ |
| D | default_expr_wrong_type.rs | 4 struct Receiver { struct
6 not_u32: String,
9 also_not_u32: Vec<String>,
|
| D | attrs_with_bad_fn.rs | 10 struct Receiver { struct
12 attrs: Vec<Attribute>,
|
| /external/rust/crates/hyper/src/common/ |
| D | watch.rs | 18 pub(crate) fn channel(initial: Value) -> (Sender, Receiver) { in channel() argument
41 pub(crate) struct Receiver { struct
64 impl Receiver { argument
|
| /external/rust/cxx/macro/src/ |
| D | tokens.rs | 9 impl Receiver { impl
23 let Receiver { in to_tokens() localVariable
51 let Receiver { in to_tokens() localVariable
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | loom_oneshot.rs | 22 pub(crate) struct Receiver<T> { struct
38 impl<T> Receiver<T> { argument
|
| /external/rust/crates/tokio/src/net/unix/ |
| D | pipe.rs | 177 pub fn open_receiver<P: AsRef<Path>>(&self, path: P) -> io::Result<Receiver> { in open_receiver()
239 Receiver, enumerator
739 pub struct Receiver { struct
740 io: PollEvented<mio_pipe::Receiver>, argument
743 impl Receiver { impl
744 fn from_mio(mio_rx: mio_pipe::Receiver) -> io::Result<Receiver> { in from_mio()
768 pub fn from_file(mut file: File) -> io::Result<Receiver> { in from_file()
823 pub fn from_file_unchecked(file: File) -> io::Result<Receiver> { in from_file_unchecked()
1152 impl AsyncRead for Receiver { implementation
1164 impl AsRawFd for Receiver { implementation
[all …]
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | counter.rs | 92 pub(crate) struct Receiver<C> { struct
96 impl<C> Receiver<C> { impl
132 impl<C> ops::Deref for Receiver<C> { implementation
140 impl<C> PartialEq for Receiver<C> { implementation
|
| D | channel.rs | 705 pub struct Receiver<T> { struct
706 flavor: ReceiverFlavor<T>, argument
730 unsafe impl<T: Send> Send for Receiver<T> {} implementation
731 unsafe impl<T: Send> Sync for Receiver<T> {} implementation
733 impl<T> UnwindSafe for Receiver<T> {} implementation
734 impl<T> RefUnwindSafe for Receiver<T> {} implementation
736 impl<T> Receiver<T> { impl
1150 impl<T> Drop for Receiver<T> { implementation
1165 impl<T> Clone for Receiver<T> { implementation
1180 impl<T> fmt::Debug for Receiver<T> { implementation
[all …]
|
| /external/rust/crates/darling/tests/ |
| D | attrs_with.rs | 28 struct Receiver { struct
36 let di = Receiver::from_derive_input(&parse_quote! { in succeeds_on_no_attrs() argument
|
| D | enums_default.rs | 19 struct Receiver { struct
26 let di = Receiver::from_derive_input(&parse_quote! { in missing_meta() argument
|
| /external/rust/crates/futures-channel/src/ |
| D | oneshot.rs | 19 pub struct Receiver<T> { struct
31 impl<T> Unpin for Receiver<T> {} implementation
430 impl<T> Receiver<T> { implementation
455 impl<T> Future for Receiver<T> { implementation
463 impl<T> FusedFuture for Receiver<T> { implementation
478 impl<T> Drop for Receiver<T> { implementation
484 impl<T> fmt::Debug for Receiver<T> { implementation
|
| /external/rust/crates/darling/examples/ |
| D | expr_with.rs | 6 pub struct Receiver { struct
12 let input = Receiver::from_derive_input(&parse_quote! { in main() argument
|
| /external/rust/crates/async-stream/src/ |
| D | yielder.rs | 14 pub struct Receiver<T> { struct
19 _rx: &'a mut Receiver<T>, argument
76 impl<T> Receiver<T> { impl
|
| /external/rust/crates/oneshot-uniffi/src/ |
| D | lib.rs | 223 pub struct Receiver<T> { struct
230 unsafe impl<T: Send> Send for Receiver<T> {} argument
231 impl<T> Unpin for Receiver<T> {} implementation
395 impl<T> Receiver<T> { impl
871 impl<T> core::future::Future for Receiver<T> { implementation
964 impl<T> Drop for Receiver<T> { implementation
|
| /external/webrtc/rtc_base/ |
| D | virtual_socket_unittest.cc | 94 struct Receiver : public sigslot::has_slots<> { struct
95 Receiver(Thread* th, Socket* s, uint32_t bw) in Receiver() function
117 ~Receiver() override { periodic.Stop(); } in ~Receiver()
119 void OnReadPacket(AsyncPacketSocket* s, in OnReadPacket()
138 Thread* thread;
139 std::unique_ptr<AsyncUDPSocket> socket;
140 uint32_t bandwidth;
141 RepeatingTaskHandle periodic;
142 size_t count;
143 size_t sec_count;
[all …]
|
| /external/rust/crates/tokio/src/sync/ |
| D | oneshot.rs | 322 pub struct Receiver<T> { struct
337 /// Error returned by the `Future` implementation for `Receiver`. argument
859 impl<T> Receiver<T> { implementation
1071 impl<T> Drop for Receiver<T> { implementation
1087 impl<T> Future for Receiver<T> { implementation
|
| D | broadcast.rs | 205 pub struct Receiver<T> { struct
207 shared: Arc<Shared<T>>,
210 next: u64,
471 unsafe impl<T: Send> Send for Receiver<T> {} implementation
472 unsafe impl<T: Send> Sync for Receiver<T> {} implementation
955 impl<T> Receiver<T> { impl
1153 impl<T: Clone> Receiver<T> { implementation
1331 impl<T> Drop for Receiver<T> { implementation
1451 impl<T> fmt::Debug for Receiver<T> { implementation
|
| D | watch.rs | 78 pub struct Receiver<T> { struct
86 /// Sends values to the associated [`Receiver`](struct@Receiver). argument
417 impl<T> Receiver<T> { implementation
761 impl<T> Clone for Receiver<T> { implementation
770 impl<T> Drop for Receiver<T> { implementation
|
| /external/rust/crates/hyper/src/client/ |
| D | dispatch.rs | 152 pub(crate) struct Receiver<T, U> { struct
153 inner: mpsc::UnboundedReceiver<Envelope<T, U>>, argument
157 impl<T, U> Receiver<T, U> { impl
185 impl<T, U> Drop for Receiver<T, U> { implementation
311 impl<T, U> Future for Receiver<T, U> { implementation
|
| /external/rust/cxx/syntax/ |
| D | impls.rs | 399 impl Eq for Receiver {} implementation
401 impl PartialEq for Receiver { implementation
403 let Receiver { in eq() localVariable
415 let Receiver { in eq() localVariable
431 impl Hash for Receiver { implementation
433 let Receiver { in hash() localVariable
|
| D | mod.rs | 236 pub(crate) struct Receiver { struct
237 pub pinned: bool,
238 pub ampersand: Token![&],
239 pub lifetime: Option<Lifetime>,
240 pub mutable: bool,
241 pub var: Token![self],
242 pub ty: NamedType,
244 pub colon_token: Token![:],
245 pub shorthand: bool,
247 pub pin_tokens: Option<(kw::Pin, Token![<], Token![>])>,
[all …]
|
| /external/python/bumble/extras/android/BtBench/app/src/main/java/com/github/google/bumble/btbench/ |
| D | Receiver.kt | 23 class Receiver(private val viewModel: AppViewModel, private val packetIO: PacketIO) : PacketSink() { class
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | bounded.rs | 94 pub struct Receiver<T> { struct
106 /// All data sent on `Sender` will become available on `Receiver` in the same argument
166 impl<T> Receiver<T> { impl
404 impl<T> fmt::Debug for Receiver<T> { implementation
412 impl<T> Unpin for Receiver<T> {} implementation
|