Home
last modified time | relevance | path

Searched defs:Receiver (Results 1 – 25 of 141) sorted by relevance

123456

/external/rust/android-crates-io/crates/tokio/src/runtime/blocking/
Dshutdown.rs17 pub(super) struct Receiver { struct
18 rx: oneshot::Receiver<()>, argument
29 impl Receiver { impl
/external/rust/android-crates-io/crates/darling/tests/compile-fail/
Ddefault_expr_wrong_type.rs4 struct Receiver { struct
6 not_u32: String,
9 also_not_u32: Vec<String>,
Dattrs_with_bad_fn.rs10 struct Receiver { struct
12 attrs: Vec<Attribute>,
/external/rust/android-crates-io/crates/hyper/src/common/
Dwatch.rs18 pub(crate) fn channel(initial: Value) -> (Sender, Receiver) { in channel() argument
41 pub(crate) struct Receiver { struct
64 impl Receiver { impl
/external/cronet/tot/third_party/rust/chromium_crates_io/vendor/cxxbridge-macro-1.0.130/src/
Dtokens.rs9 impl Receiver { implementation
23 let Receiver { in to_tokens() localVariable
51 let Receiver { in to_tokens() localVariable
/external/cronet/stable/third_party/rust/chromium_crates_io/vendor/cxxbridge-macro-1.0.130/src/
Dtokens.rs9 impl Receiver { implementation
23 let Receiver { in to_tokens() localVariable
51 let Receiver { in to_tokens() localVariable
/external/rust/cxx/macro/src/
Dtokens.rs9 impl Receiver { implementation
23 let Receiver { in to_tokens() localVariable
51 let Receiver { in to_tokens() localVariable
/external/rust/android-crates-io/crates/tokio/src/runtime/tests/
Dloom_oneshot.rs22 pub(crate) struct Receiver<T> { struct
38 impl<T> Receiver<T> { impl
/external/rust/android-crates-io/crates/tokio/src/net/unix/
Dpipe.rs229 pub fn open_receiver<P: AsRef<Path>>(&self, path: P) -> io::Result<Receiver> { in open_receiver()
291 Receiver, enumerator
861 pub struct Receiver { struct
862 io: PollEvented<mio_pipe::Receiver>, argument
865 impl Receiver { implementation
866 fn from_mio(mio_rx: mio_pipe::Receiver) -> io::Result<Receiver> { in from_mio()
890 pub fn from_file(file: File) -> io::Result<Receiver> { in from_file()
915 pub fn from_owned_fd(owned_fd: OwnedFd) -> io::Result<Receiver> { in from_owned_fd()
970 pub fn from_file_unchecked(file: File) -> io::Result<Receiver> { in from_file_unchecked()
990 pub fn from_owned_fd_unchecked(owned_fd: OwnedFd) -> io::Result<Receiver> { in from_owned_fd_unchecked()
[all …]
/external/rust/android-crates-io/crates/crossbeam-channel/src/
Dcounter.rs93 pub(crate) struct Receiver<C> { struct
97 impl<C> Receiver<C> { impl
133 impl<C> ops::Deref for Receiver<C> { implementation
141 impl<C> PartialEq for Receiver<C> { implementation
Dchannel.rs705 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/android-crates-io/crates/darling/tests/
Dattrs_with.rs28 struct Receiver { struct
36 let di = Receiver::from_derive_input(&parse_quote! { in succeeds_on_no_attrs() argument
Denums_default.rs19 struct Receiver { struct
26 let di = Receiver::from_derive_input(&parse_quote! { in missing_meta() argument
/external/rust/android-crates-io/crates/futures-channel/src/
Doneshot.rs19 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/android-crates-io/crates/darling/examples/
Dexpr_with.rs6 pub struct Receiver { struct
12 let input = Receiver::from_derive_input(&parse_quote! { in main() argument
/external/rust/android-crates-io/crates/async-stream/src/
Dyielder.rs14 pub struct Receiver<T> { struct
19 _rx: &'a mut Receiver<T>, argument
76 impl<T> Receiver<T> { impl
/external/webrtc/rtc_base/
Dvirtual_socket_unittest.cc94 struct Receiver : public sigslot::has_slots<> { struct
95 Receiver(Thread* th, Socket* s, uint32_t bw) in Receiver() argument
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/android-crates-io/crates/tokio/src/sync/
Doneshot.rs322 pub struct Receiver<T> { struct
337 /// Error returned by the `Future` implementation for `Receiver`. argument
860 impl<T> Receiver<T> { impl
1072 impl<T> Drop for Receiver<T> { implementation
1095 impl<T> Future for Receiver<T> { implementation
Dbroadcast.rs205 pub struct Receiver<T> { struct
207 shared: Arc<Shared<T>>,
210 next: u64,
473 unsafe impl<T: Send> Send for Receiver<T> {} implementation
474 unsafe impl<T: Send> Sync for Receiver<T> {} implementation
962 impl<T> Receiver<T> { impl
1165 impl<T: Clone> Receiver<T> { impl
1343 impl<T> Drop for Receiver<T> { implementation
1478 impl<T> fmt::Debug for Receiver<T> { implementation
/external/rust/android-crates-io/crates/hyper/src/client/
Ddispatch.rs152 pub(crate) struct Receiver<T, U> { struct
153 inner: mpsc::UnboundedReceiver<Envelope<T, U>>, argument
157 impl<T, U> Receiver<T, U> { implementation
185 impl<T, U> Drop for Receiver<T, U> { implementation
311 impl<T, U> Future for Receiver<T, U> { implementation
/external/cronet/tot/third_party/rust/chromium_crates_io/vendor/cxxbridge-macro-1.0.130/src/syntax/
Dimpls.rs399 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
/external/cronet/stable/third_party/rust/chromium_crates_io/vendor/cxxbridge-macro-1.0.130/src/syntax/
Dimpls.rs399 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
/external/cronet/tot/third_party/rust/chromium_crates_io/vendor/cxxbridge-cmd-1.0.131/src/syntax/
Dimpls.rs399 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
/external/cronet/stable/third_party/rust/chromium_crates_io/vendor/cxxbridge-cmd-1.0.131/src/syntax/
Dimpls.rs399 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
/external/rust/cxx/syntax/
Dimpls.rs399 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

123456