| /external/rust/crates/mio/src/sys/unix/ |
| D | pipe.rs | 377 pub struct Receiver { struct
381 impl Receiver { argument
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/cxx/macro/src/ |
| D | tokens.rs | 9 impl Receiver { implementation
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/crossbeam-channel/src/ |
| D | counter.rs | 92 pub(crate) struct Receiver<C> { struct
96 impl<C> Receiver<C> { implementation
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> { implementation
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/futures-channel/src/ |
| D | oneshot.rs | 19 pub struct Receiver<T> { struct
31 impl<T> Unpin for Receiver<T> {} argument
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/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/tokio/src/sync/ |
| D | broadcast.rs | 200 pub struct Receiver<T> { struct
202 shared: Arc<Shared<T>>,
205 next: u64,
484 unsafe impl<T: Send> Send for Receiver<T> {} implementation
485 unsafe impl<T: Send> Sync for Receiver<T> {} implementation
795 impl<T> Receiver<T> { impl
960 impl<T: Clone> Receiver<T> { impl
1111 impl<T> Drop for Receiver<T> { implementation
1229 impl<T> fmt::Debug for Receiver<T> { implementation
|
| D | oneshot.rs | 318 pub struct Receiver<T> { struct
333 /// Error returned by the `Future` implementation for `Receiver`. argument
853 impl<T> Receiver<T> { impl
1064 impl<T> Drop for Receiver<T> { implementation
1080 impl<T> Future for Receiver<T> { implementation
|
| D | watch.rs | 74 pub struct Receiver<T> { struct
82 /// Sends values to the associated [`Receiver`](struct@Receiver). argument
339 impl<T> Receiver<T> { implementation
587 impl<T> Clone for Receiver<T> { implementation
596 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/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 | 204 pub struct Receiver { struct
205 pub pinned: bool,
206 pub ampersand: Token![&],
207 pub lifetime: Option<Lifetime>,
208 pub mutable: bool,
209 pub var: Token![self],
210 pub ty: NamedType,
211 pub colon_token: Token![:],
212 pub shorthand: bool,
213 pub pin_tokens: Option<(kw::Pin, Token![<], Token![>])>,
[all …]
|
| /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
403 impl<T> fmt::Debug for Receiver<T> { implementation
411 impl<T> Unpin for Receiver<T> {} implementation
|
| /external/openscreen/cast/streaming/ |
| D | receiver_packet_router.h | 21 class Receiver; variable
|
| /external/robolectric/robolectric/src/test/java/com/foo/ |
| D | Receiver.java | 7 public class Receiver extends BroadcastReceiver { class
|
| /external/robolectric-shadows/robolectric/src/test/java/com/foo/ |
| D | Receiver.java | 7 public class Receiver extends BroadcastReceiver { class
|
| /external/cronet/components/metrics/ |
| D | child_call_stack_profile_collector_unittest.cc | 30 class Receiver : public mojom::CallStackProfileCollector { class in metrics::ChildCallStackProfileCollectorTest
32 explicit Receiver( in Receiver() function in metrics::ChildCallStackProfileCollectorTest::Receiver
|
| /external/cronet/base/ |
| D | scoped_generic.h | 193 explicit Receiver(ScopedGeneric& parent) : scoped_generic_(&parent) { in Receiver() function
201 Receiver(Receiver&& move) { in Receiver() function
|
| /external/clang/lib/AST/ |
| D | ExprObjC.cpp | 141 TypeSourceInfo *Receiver, Selector Sel, in ObjCMessageExpr()
158 SourceLocation LBracLoc, Expr *Receiver, in ObjCMessageExpr()
222 SourceLocation LBracLoc, TypeSourceInfo *Receiver, in Create()
241 SourceLocation LBracLoc, Expr *Receiver, Selector Sel, in Create()
|
| /external/rust/crates/futures-channel/src/mpsc/ |
| D | mod.rs | 136 pub struct Receiver<T> { struct
143 pub struct UnboundedReceiver<T> { argument
959 impl<T> Receiver<T> { impl
1051 impl<T> Unpin for Receiver<T> {} implementation
1053 impl<T> FusedStream for Receiver<T> { implementation
1059 impl<T> Stream for Receiver<T> { implementation
1091 impl<T> Drop for Receiver<T> { implementation
1121 impl<T> fmt::Debug for Receiver<T> { implementation
|
| /external/webrtc/call/ |
| D | rtp_stream_receiver_controller.cc | 19 RtpStreamReceiverController::Receiver::Receiver( in Receiver() function in webrtc::RtpStreamReceiverController::Receiver
|
| /external/rust/crates/syn-mid/src/ |
| D | func.rs | 160 impl Parse for Receiver { implementation
255 impl ToTokens for Receiver { implementation
|
| /external/openthread/src/core/net/ |
| D | udp6.hpp | 301 class Receiver : public otUdpReceiver, public LinkedListEntry<Receiver> class in ot::Ip6::Udp
313 Receiver(otUdpHandler aHandler, void *aContext) in Receiver() function in ot::Ip6::Udp::Receiver
|