| /external/rust/crates/hyper/src/common/ |
| D | watch.rs | 18 pub(crate) fn channel(initial: Value) -> (Sender, Receiver) { in channel()
37 pub(crate) struct Sender { struct
50 impl Sender { impl
58 impl Drop for Sender { implementation
|
| /external/rust/crates/mio/src/sys/unix/ |
| D | pipe.rs | 212 pub struct Sender { struct
216 impl Sender { argument
291 impl event::Source for Sender { implementation
315 impl Write for Sender { implementation
329 impl Write for &Sender { implementation
346 impl From<ChildStdin> for Sender { implementation
347 fn from(stdin: ChildStdin) -> Sender { in from()
353 impl FromRawFd for Sender { implementation
354 unsafe fn from_raw_fd(fd: RawFd) -> Sender { in from_raw_fd()
361 impl AsRawFd for Sender { implementation
[all …]
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | loom_oneshot.rs | 18 pub(crate) struct Sender<T> { struct
31 impl<T> Sender<T> { implementation
|
| /external/rust/crates/tokio/src/net/unix/ |
| D | pipe.rs | 203 pub fn open_sender<P: AsRef<Path>>(&self, path: P) -> io::Result<Sender> { in open_sender()
238 Sender, enumerator
313 pub struct Sender { struct
314 io: PollEvented<mio_pipe::Sender>, argument
317 impl Sender { implementation
318 fn from_mio(mio_tx: mio_pipe::Sender) -> io::Result<Sender> { in from_mio()
342 pub fn from_file(mut file: File) -> io::Result<Sender> { in from_file()
397 pub fn from_file_unchecked(file: File) -> io::Result<Sender> { in from_file_unchecked()
629 impl AsyncWrite for Sender { implementation
659 impl AsRawFd for Sender { implementation
[all …]
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | counter.rs | 37 pub(crate) struct Sender<C> { struct
41 impl<C> Sender<C> { argument
77 impl<C> ops::Deref for Sender<C> { implementation
85 impl<C> PartialEq for Sender<C> { implementation
|
| D | channel.rs | 355 pub struct Sender<T> { struct
356 flavor: SenderFlavor<T>, argument
371 unsafe impl<T: Send> Send for Sender<T> {} implementation
372 unsafe impl<T: Send> Sync for Sender<T> {} implementation
374 impl<T> UnwindSafe for Sender<T> {} implementation
375 impl<T> RefUnwindSafe for Sender<T> {} implementation
377 impl<T> Sender<T> { impl
655 impl<T> Drop for Sender<T> { implementation
667 impl<T> Clone for Sender<T> { implementation
679 impl<T> fmt::Debug for Sender<T> { implementation
[all …]
|
| /external/rust/crates/async-stream/src/ |
| D | yielder.rs | 9 pub struct Sender<T> { struct
28 pub unsafe fn pair<T>() -> (Sender<T>, Receiver<T>) { in pair() argument
41 impl<T> Sender<T> { impl
|
| /external/rust/crates/futures-channel/src/ |
| D | oneshot.rs | 26 pub struct Sender<T> { struct
32 impl<T> Unpin for Sender<T> {} implementation
331 impl<T> Sender<T> { impl
387 impl<T> Drop for Sender<T> { implementation
393 impl<T> fmt::Debug for Sender<T> { implementation
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | shutdown.rs | 12 pub(super) struct Sender { struct
13 _tx: Arc<oneshot::Sender<()>>, argument
|
| /external/rust/crates/oneshot-uniffi/src/ |
| D | lib.rs | 201 pub struct Sender<T> { struct
224 // Covariance is the right choice here. Consider the example presented in Sender, and you'll argument
229 unsafe impl<T: Send> Send for Sender<T> {} implementation
233 impl<T> Sender<T> { implementation
344 impl<T> Drop for Sender<T> { implementation
|
| /external/webrtc/rtc_base/ |
| D | virtual_socket_unittest.cc | 57 struct Sender { struct
58 Sender(Thread* th, Socket* s, uint32_t rt) in Sender() function
79 TimeDelta NextDelay() { in NextDelay()
84 Thread* thread;
85 std::unique_ptr<AsyncUDPSocket> socket;
86 rtc::PacketOptions options;
87 RepeatingTaskHandle periodic;
88 uint32_t rate; // bytes per second
89 uint32_t count;
90 int64_t last_send;
[all …]
|
| /external/rust/crates/hyper/src/body/ |
| D | body.rs | 111 pub struct Sender { struct
113 data_tx: BodySender, argument
114 trailers_tx: Option<TrailersSender>, argument
144 pub(crate) fn new_channel(content_length: DecodedLength, wanter: bool) -> (Sender, Body) { in new_channel()
553 impl Sender { impl
625 impl fmt::Debug for Sender { implementation
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | bounded.rs | 22 pub struct Sender<T> { struct
28 /// If all [`Sender`] instances of a channel were dropped and only `WeakSender` argument
414 impl<T> Sender<T> { implementation
1092 impl<T> Clone for Sender<T> { implementation
1100 impl<T> fmt::Debug for Sender<T> { implementation
|
| /external/rust/crates/hyper/src/client/ |
| D | dispatch.rs | 30 pub(crate) struct Sender<T, U> { struct
41 inner: mpsc::UnboundedSender<Envelope<T, U>>, argument
55 impl<T, U> Sender<T, U> { implementation
|
| /external/rust/crates/uniffi_core/src/ffi/rustfuture/ |
| D | tests.rs | 19 struct Sender(Arc<Mutex<Channel>>); struct
21 impl Sender { implementation
|
| /external/python/bumble/extras/android/BtBench/app/src/main/java/com/github/google/bumble/btbench/ |
| D | Sender.kt | 24 class Sender(private val viewModel: AppViewModel, private val packetIO: PacketIO) : PacketSink() { class
|
| /external/rust/crates/tokio/src/sync/ |
| D | broadcast.rs | 165 pub struct Sender<T> { struct
166 shared: Arc<Shared<T>>,
468 unsafe impl<T: Send> Send for Sender<T> {} implementation
469 unsafe impl<T: Send> Sync for Sender<T> {} implementation
474 impl<T> Sender<T> { impl
938 impl<T> Clone for Sender<T> { implementation
947 impl<T> Drop for Sender<T> { implementation
1445 impl<T> fmt::Debug for Sender<T> { implementation
|
| D | oneshot.rs | 222 pub struct Sender<T> { struct
228 /// Receives a value from the associated [`Sender`]. argument
553 impl<T> Sender<T> { implementation
843 impl<T> Drop for Sender<T> { implementation
|
| D | watch.rs | 90 pub struct Sender<T> { struct
91 shared: Arc<Shared<T>>,
781 impl<T> Sender<T> { impl
1146 impl<T> Drop for Sender<T> { implementation
|
| /external/clang/test/CodeGenCXX/ |
| D | pr24097.cpp | 6 struct Sender { struct
|
| /external/libchrome/ipc/ |
| D | ipc_test_channel_listener.h | 14 class Sender; variable
|
| /external/cronet/ipc/ |
| D | ipc_test_channel_listener.h | 15 class Sender; variable
|
| /external/rust/crates/tokio/tests/ |
| D | sync_oneshot.rs | 21 impl AssertSend for oneshot::Sender<i32> {} implementation
27 impl<T> SenderExt for oneshot::Sender<T> { implementation
|
| /external/clang/test/CodeGen/ |
| D | available-externally-hidden.cpp | 12 class Sender { class
|
| /external/crosvm/cros_async/src/sync/ |
| D | cv.rs | 621 async fn wait(mu: Arc<RwLock<()>>, cv: Arc<Condvar>, tx: Sender<()>, pool: ThreadPool) { in notify_one_multi_thread_async()
669 async fn increment(mu: Arc<RwLock<usize>>, cv: Arc<Condvar>, done: Sender<()>) { in notify_one_with_cancel()
683 done: Sender<()>, in notify_one_with_cancel()
700 done: Sender<()>, in notify_one_with_cancel()
771 async fn increment(mu: Arc<RwLock<usize>>, cv: Arc<Condvar>, done: Sender<()>) { in notify_all_with_cancel()
785 done: Sender<()>, in notify_all_with_cancel()
927 tx: Sender<()>, in notify_all_multi_thread_async()
|