| /external/rust/crates/mio/src/sys/unix/ |
| D | pipe.rs | 212 pub struct Sender { struct
216 impl Sender { implementation
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> { impl
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | counter.rs | 37 pub(crate) struct Sender<C> { struct
41 impl<C> Sender<C> { impl
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> { implementation
|
| /external/rust/crates/futures-channel/src/ |
| D | oneshot.rs | 26 pub struct Sender<T> { struct
32 impl<T> Unpin for Sender<T> {} argument
331 impl<T> Sender<T> { implementation
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/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/tokio/src/sync/ |
| D | broadcast.rs | 160 pub struct Sender<T> { struct
161 shared: Arc<Shared<T>>,
481 unsafe impl<T: Send> Send for Sender<T> {} implementation
482 unsafe impl<T: Send> Sync for Sender<T> {} implementation
487 impl<T> Sender<T> { implementation
778 impl<T> Clone for Sender<T> { implementation
787 impl<T> Drop for Sender<T> { implementation
1223 impl<T> fmt::Debug for Sender<T> { implementation
|
| D | oneshot.rs | 218 pub struct Sender<T> { struct
224 /// Receives a value from the associated [`Sender`]. argument
549 impl<T> Sender<T> { implementation
837 impl<T> Drop for Sender<T> { implementation
|
| D | watch.rs | 86 pub struct Sender<T> { struct
87 shared: Arc<Shared<T>>,
607 impl<T> Sender<T> { implementation
970 impl<T> Drop for Sender<T> { 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
413 impl<T> Sender<T> { impl
1088 impl<T> Clone for Sender<T> { implementation
1096 impl<T> fmt::Debug 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
|
| D | ipc_logging.h | 33 class Sender; variable
|
| /external/cronet/ipc/ |
| D | ipc_test_channel_listener.h | 15 class Sender; variable
|
| D | ipc_logging.h | 35 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/libchromeos-rs/src/sync/ |
| D | cv.rs | 620 async fn wait(mu: Arc<Mutex<()>>, cv: Arc<Condvar>, tx: Sender<()>, pool: ThreadPool) { in notify_one_multi_thread_async()
667 async fn increment(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>, done: Sender<()>) { in notify_one_with_cancel()
681 done: Sender<()>, in notify_one_with_cancel()
698 done: Sender<()>, in notify_one_with_cancel()
769 async fn increment(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>, done: Sender<()>) { in notify_all_with_cancel()
783 done: Sender<()>, in notify_all_with_cancel()
925 tx: Sender<()>, in notify_all_multi_thread_async()
|
| /external/crosvm/cros_async/src/sync/ |
| D | cv.rs | 607 async fn wait(mu: Arc<Mutex<()>>, cv: Arc<Condvar>, tx: Sender<()>, pool: ThreadPool) { in notify_one_multi_thread_async()
654 async fn increment(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>, done: Sender<()>) { in notify_one_with_cancel()
668 done: Sender<()>, in notify_one_with_cancel()
685 done: Sender<()>, in notify_one_with_cancel()
756 async fn increment(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>, done: Sender<()>) { in notify_all_with_cancel()
770 done: Sender<()>, in notify_all_with_cancel()
912 tx: Sender<()>, in notify_all_multi_thread_async()
|
| /external/openscreen/cast/standalone_sender/ |
| D | streaming_vpx_encoder.h | 34 class Sender; variable
|
| D | streaming_av1_encoder.h | 34 class Sender; variable
|
| /external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/rtsp/src/main/java/com/google/android/exoplayer2/source/rtsp/ |
| D | RtspMessageChannel.java | 201 private final class Sender implements Closeable { class in RtspMessageChannel
213 public Sender(OutputStream outputStream) { in Sender() method in RtspMessageChannel.Sender
|
| /external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/rtsp/src/main/java/com/google/android/exoplayer2/source/rtsp/ |
| D | RtspMessageChannel.java | 203 private final class Sender implements Closeable { class in RtspMessageChannel
215 public Sender(OutputStream outputStream) { in Sender() method in RtspMessageChannel.Sender
|