| /external/rust/crates/mio/src/sys/unix/ |
| D | pipe.rs | 307 pub struct Receiver { struct
311 impl Receiver { argument
318 impl event::Source for Receiver { implementation
342 impl Read for Receiver { implementation
352 impl Read for &Receiver { implementation
365 impl From<ChildStdout> for Receiver { implementation
366 fn from(stdout: ChildStdout) -> Receiver { in from()
375 impl From<ChildStderr> for Receiver { implementation
376 fn from(stderr: ChildStderr) -> Receiver { in from()
382 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/tokio/src/runtime/tests/ |
| D | loom_oneshot.rs | 22 pub(crate) struct Receiver<T> { struct
38 impl<T> Receiver<T> { implementation
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | counter.rs | 92 pub(crate) struct Receiver<C> { struct
96 impl<C> Receiver<C> { argument
132 impl<C> ops::Deref for Receiver<C> { implementation
140 impl<C> PartialEq for Receiver<C> { implementation
|
| D | channel.rs | 691 pub struct Receiver<T> { struct
692 flavor: ReceiverFlavor<T>, argument
716 unsafe impl<T: Send> Send for Receiver<T> {} implementation
717 unsafe impl<T: Send> Sync for Receiver<T> {} implementation
719 impl<T> UnwindSafe for Receiver<T> {} implementation
720 impl<T> RefUnwindSafe for Receiver<T> {} implementation
722 impl<T> Receiver<T> { impl
1133 impl<T> Drop for Receiver<T> { implementation
1148 impl<T> Clone for Receiver<T> { implementation
1163 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> 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
71 impl<T> Receiver<T> { implementation
|
| /external/rust/crates/tokio/src/sync/ |
| D | broadcast.rs | 197 pub struct Receiver<T> { struct
199 shared: Arc<Shared<T>>,
202 next: u64,
471 unsafe impl<T: Send> Send for Receiver<T> {} implementation
472 unsafe impl<T: Send> Sync for Receiver<T> {} implementation
693 impl<T> Receiver<T> { implementation
811 impl<T: Clone> Receiver<T> { impl
935 impl<T> Drop for Receiver<T> { implementation
1053 impl<T> fmt::Debug for Receiver<T> { implementation
|
| D | watch.rs | 73 pub struct Receiver<T> { struct
81 /// Sends values to the associated [`Receiver`](struct@Receiver). argument
269 impl<T> Receiver<T> { implementation
405 impl<T> Clone for Receiver<T> { implementation
414 impl<T> Drop for Receiver<T> { implementation
|
| D | oneshot.rs | 303 pub struct Receiver<T> { struct
312 /// Error returned by the `Future` implementation for `Receiver`. argument
732 impl<T> Receiver<T> { implementation
890 impl<T> Drop for Receiver<T> { implementation
898 impl<T> Future for Receiver<T> { implementation
|
| /external/webrtc/rtc_base/ |
| D | virtual_socket_unittest.cc | 102 struct Receiver : public MessageHandler, public sigslot::has_slots<> { struct
103 Receiver(Thread* th, AsyncSocket* s, uint32_t bw) in Receiver() function
117 ~Receiver() override { thread->Clear(this); } in ~Receiver()
119 void OnReadPacket(AsyncPacketSocket* s, in OnReadPacket()
138 void OnMessage(Message* pmsg) override { in OnMessage()
152 Thread* thread;
153 std::unique_ptr<AsyncUDPSocket> socket;
154 uint32_t bandwidth;
155 bool done;
156 size_t count;
[all …]
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | bounded.rs | 59 pub struct Receiver<T> { struct
71 /// All data sent on `Sender` will become available on `Receiver` in the same argument
123 impl<T> Receiver<T> { implementation
359 impl<T> fmt::Debug for Receiver<T> { implementation
367 impl<T> Unpin for Receiver<T> {} implementation
|
| /external/rust/cxx/syntax/ |
| D | impls.rs | 389 impl Eq for Receiver {} implementation
391 impl PartialEq for Receiver { implementation
393 let Receiver { in eq() localVariable
405 let Receiver { in eq() localVariable
421 impl Hash for Receiver { implementation
423 let Receiver { in hash() localVariable
|
| D | mod.rs | 187 pub struct Receiver { struct
188 pub pinned: bool,
189 pub ampersand: Token![&],
190 pub lifetime: Option<Lifetime>,
191 pub mutable: bool,
192 pub var: Token![self],
193 pub ty: NamedType,
194 pub colon_token: Token![:],
195 pub shorthand: bool,
196 pub pin_tokens: Option<(kw::Pin, Token![<], Token![>])>,
[all …]
|
| D | tokens.rs | 303 impl Receiver { impl
317 let Receiver { in to_tokens() localVariable
345 let Receiver { in to_tokens() localVariable
|
| /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/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 | 141 pub struct Receiver<T> { struct
149 pub struct UnboundedReceiver<T> { argument
956 impl<T> Receiver<T> { implementation
1048 impl<T> Unpin for Receiver<T> {} implementation
1050 impl<T> FusedStream for Receiver<T> { implementation
1056 impl<T> Stream for Receiver<T> { implementation
1080 impl<T> Drop for Receiver<T> { implementation
|
| /external/rust/crates/syn-mid/src/ |
| D | func.rs | 160 impl Parse for Receiver { implementation
255 impl ToTokens for Receiver { implementation
|
| /external/clang/lib/StaticAnalyzer/Checkers/ |
| D | NoReturnFunctionChecker.cpp | 113 const ObjCInterfaceDecl *Receiver = Msg.getReceiverInterface(); in checkPostObjCMessage() local
|
| /external/rust/crates/tokio/src/signal/ |
| D | mod.rs | 72 async fn make_future(mut rx: Receiver<()>) -> Receiver<()> { in make_future()
|
| /external/mockito/src/test/java/org/mockitousage/annotation/ |
| D | InjectionOfInlinedMockDeclarationTest.java | 55 static class Receiver { class in InjectionOfInlinedMockDeclarationTest
|
| /external/webrtc/call/ |
| D | rtp_stream_receiver_controller.cc | 19 RtpStreamReceiverController::Receiver::Receiver( in Receiver() function in webrtc::RtpStreamReceiverController::Receiver
|