| /external/openscreen/cast/streaming/ |
| D | receiver.cc | 30 Receiver::Receiver(Environment* environment, in Receiver() function in openscreen::cast::Receiver
62 Receiver::~Receiver() { in ~Receiver()
66 void Receiver::SetConsumer(Consumer* consumer) { in SetConsumer()
71 void Receiver::SetPlayerProcessingTime(Clock::duration needed_time) { in SetPlayerProcessingTime()
75 void Receiver::RequestKeyFrame() { in RequestKeyFrame()
87 int Receiver::AdvanceToNextFrame() { in AdvanceToNextFrame()
138 EncodedFrame Receiver::ConsumeNextFrame(absl::Span<uint8_t> buffer) { in ConsumeNextFrame()
174 void Receiver::OnReceivedRtpPacket(Clock::time_point arrival_time, in OnReceivedRtpPacket()
290 void Receiver::OnReceivedRtcpPacket(Clock::time_point arrival_time, in OnReceivedRtcpPacket()
329 void Receiver::SendRtcp() { in SendRtcp()
[all …]
|
| D | receiver_packet_router.h | 21 class Receiver; variable
34 friend class Receiver;
39 void OnReceiverCreated(Ssrc sender_ssrc, Receiver* receiver);
55 FlatMap<Ssrc, Receiver*> receivers_;
|
| D | receiver_session.h | 27 class Receiver; variable
46 Receiver* audio_receiver;
49 Receiver* video_receiver;
143 std::unique_ptr<Receiver> ConstructReceiver(const Stream& stream);
174 std::unique_ptr<Receiver> current_audio_receiver_;
175 std::unique_ptr<Receiver> current_video_receiver_;
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | mpsc_bounded.rs | 4 use tokio::sync::mpsc::Receiver;
12 inner: Receiver<T>,
17 pub fn new(recv: Receiver<T>) -> Self { in new()
22 pub fn into_inner(self) -> Receiver<T> { in into_inner()
49 impl<T> AsRef<Receiver<T>> for ReceiverStream<T> {
50 fn as_ref(&self) -> &Receiver<T> { in as_ref()
55 impl<T> AsMut<Receiver<T>> for ReceiverStream<T> {
56 fn as_mut(&mut self) -> &mut Receiver<T> { in as_mut()
|
| D | watch.rs | 2 use tokio::sync::watch::Receiver;
52 inner: ReusableBoxFuture<(Result<(), RecvError>, Receiver<T>)>,
56 mut rx: Receiver<T>, in make_future()
57 ) -> (Result<(), RecvError>, Receiver<T>) { in make_future()
64 pub fn new(rx: Receiver<T>) -> Self { in new()
|
| D | broadcast.rs | 3 use tokio::sync::broadcast::Receiver;
17 inner: ReusableBoxFuture<(Result<T, RecvError>, Receiver<T>)>,
30 async fn make_future<T: Clone>(mut rx: Receiver<T>) -> (Result<T, RecvError>, Receiver<T>) { in make_future()
37 pub fn new(rx: Receiver<T>) -> Self { in new()
|
| /external/llvm-project/clang/lib/DirectoryWatcher/mac/ |
| D | DirectoryWatcher-mac.cpp | 51 Receiver, in DirectoryWatcherMac() argument
53 : Queue(Queue), EventStream(EventStream), Receiver(Receiver), in DirectoryWatcherMac()
63 Receiver( in ~DirectoryWatcherMac()
76 std::function<void(llvm::ArrayRef<Event>, bool)> Receiver; member in __anonc5a7b2840111::DirectoryWatcherMac
82 std::function<void(llvm::ArrayRef<DirectoryWatcher::Event>, bool)> Receiver; member
87 Receiver) in EventStreamContextData()
88 : WatchedPath(std::move(WatchedPath)), Receiver(Receiver) {} in EventStreamContextData()
156 ctx->Receiver(Events, /*IsInitial=*/false); in eventStreamCallback()
162 std::function<void(llvm::ArrayRef<DirectoryWatcher::Event>, bool)> Receiver, in createFSEventStream() argument
192 Context.info = new EventStreamContextData(std::move(RealPath), Receiver); in createFSEventStream()
[all …]
|
| /external/rust/crates/mio/src/sys/unix/ |
| D | pipe.rs | 147 pub fn new() -> io::Result<(Sender, Receiver)> { in new()
201 let r = unsafe { Receiver::from_raw_fd(fds[0]) }; in new()
307 pub struct Receiver { struct
311 impl Receiver { implementation
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() argument
368 unsafe { Receiver::from_raw_fd(stdout.into_raw_fd()) } in from()
[all …]
|
| /external/rust/crates/syn/tests/ |
| D | test_receiver.rs | 1 use syn::{parse_quote, FnArg, Receiver, TraitItemMethod};
75 Some(FnArg::Receiver(Receiver { in test_value_shorthand()
90 Some(FnArg::Receiver(Receiver { in test_mut_value_shorthand()
105 Some(FnArg::Receiver(Receiver { in test_ref_shorthand()
120 Some(FnArg::Receiver(Receiver { in test_ref_mut_shorthand()
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | counter.rs | 24 pub fn new<C>(chan: C) -> (Sender<C>, Receiver<C>) { in new()
32 let r = Receiver { counter }; in new()
92 pub struct Receiver<C> { struct
96 impl<C> Receiver<C> { argument
103 pub fn acquire(&self) -> Receiver<C> { in acquire()
113 Receiver { in acquire()
132 impl<C> ops::Deref for Receiver<C> { implementation
140 impl<C> PartialEq for Receiver<C> { implementation
141 fn eq(&self, other: &Receiver<C>) -> bool { in eq()
|
| D | channel.rs | 45 pub fn unbounded<T>() -> (Sender<T>, Receiver<T>) { in unbounded()
50 let r = Receiver { in unbounded()
106 pub fn bounded<T>(cap: usize) -> (Sender<T>, Receiver<T>) { in bounded()
112 let r = Receiver { in bounded()
121 let r = Receiver { in bounded()
173 pub fn after(duration: Duration) -> Receiver<Instant> { in after()
174 Receiver { in after()
221 pub fn at(when: Instant) -> Receiver<Instant> { in at()
222 Receiver { in at()
262 pub fn never<T>() -> Receiver<T> { in never()
[all …]
|
| /external/openscreen/osp/impl/presentation/ |
| D | presentation_receiver.cc | 103 ErrorOr<size_t> Receiver::OnStreamMessage(uint64_t endpoint_id, in OnStreamMessage()
327 Receiver* Receiver::Get() { in Get()
328 static Receiver& receiver = *new Receiver(); in Get()
332 void Receiver::Init() { in Init()
339 void Receiver::Deinit() { in Deinit()
343 void Receiver::SetReceiverDelegate(ReceiverDelegate* delegate) { in SetReceiverDelegate()
374 Error Receiver::OnPresentationStarted(const std::string& presentation_id, in OnPresentationStarted()
424 Error Receiver::OnConnectionCreated(uint64_t request_id, in OnConnectionCreated()
458 Error Receiver::CloseConnection(Connection* connection, in CloseConnection()
475 Error Receiver::OnPresentationTerminated(const std::string& presentation_id, in OnPresentationTerminated()
[all …]
|
| /external/libchrome/base/timer/ |
| D | timer.h | 130 template <class Receiver>
133 Receiver* receiver, in Start()
134 void (Receiver::*method)()) { in Start()
302 template <class Receiver>
305 Receiver* receiver, in DelayTimer()
306 void (Receiver::*method)()) in DelayTimer()
309 template <class Receiver>
312 Receiver* receiver, in DelayTimer()
313 void (Receiver::*method)(), in DelayTimer()
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | shutdown.rs | 17 pub(super) struct Receiver { struct
18 rx: oneshot::Receiver<()>, argument
21 pub(super) fn channel() -> (Sender, Receiver) { in channel()
24 let rx = Receiver { rx }; in channel()
29 impl Receiver { impl
|
| /external/webrtc/call/ |
| D | rtp_stream_receiver_controller.cc | 19 RtpStreamReceiverController::Receiver::Receiver( in Receiver() function in webrtc::RtpStreamReceiverController::Receiver
33 RtpStreamReceiverController::Receiver::~Receiver() { in ~Receiver()
51 return std::make_unique<Receiver>(this, ssrc, sink); in CreateReceiver()
|
| /external/rust/crates/tokio/src/signal/ |
| D | mod.rs | 45 use crate::sync::watch::Receiver;
69 inner: ReusableBoxFuture<Receiver<()>>,
72 async fn make_future(mut rx: Receiver<()>) -> Receiver<()> { in make_future() argument
80 fn new(rx: Receiver<()>) -> Self { in new()
|
| /external/llvm-project/clang/test/Index/ |
| D | cursor-dynamic-call.mm | 75 // CHECK: 25:3 ObjCMessageExpr=meth:14:8 {{.*}} Dynamic-call Receiver-type=ObjCObjectPointer
78 // CHECK: 29:3 {{.*}} Receiver-type=ObjCInterface
79 // CHECK: 34:7 MemberRefExpr=meth:3:16 {{.*}} Dynamic-call Receiver-type=Pointer
80 // CHECK: 35:3 ObjCMessageExpr=meth:14:8 {{.*}} Dynamic-call Receiver-type=ObjCObjectPointer
82 // CHECK: 36:3 {{.*}} Receiver-type=ObjCInterface
83 // CHECK: 37:3 ObjCMessageExpr=ClsMeth:15:8 {{.*}} Dynamic-call Receiver-type=ObjCClass
85 // CHECK: 57:12 MemberRefExpr=someProp:53:23 {{.*}} Dynamic-call Receiver-type=ObjCObjectPoint…
|
| /external/webrtc/modules/audio_coding/test/ |
| D | EncodeDecodeTest.cc | 100 Receiver::Receiver() in Receiver() function in webrtc::Receiver
104 void Receiver::Setup(AudioCodingModule* acm, in Setup()
154 void Receiver::Teardown() { in Teardown()
159 bool Receiver::IncomingPacket() { in IncomingPacket()
186 bool Receiver::PlayoutData() { in PlayoutData()
206 void Receiver::Run() { in Run()
261 Receiver receiver; in Perform()
|
| /external/rust/crates/tokio/src/sync/ |
| D | broadcast.rs | 197 pub struct Receiver<T> { struct
371 receiver: &'a mut Receiver<T>,
428 pub fn channel<T: Clone>(mut capacity: usize) -> (Sender<T>, Receiver<T>) { in channel()
458 let rx = Receiver { in channel()
471 unsafe impl<T: Send> Send for Receiver<T> {} implementation
472 unsafe impl<T: Send> Sync for Receiver<T> {} implementation
553 pub fn subscribe(&self) -> Receiver<T> { in subscribe()
645 fn new_receiver<T>(shared: Arc<Shared<T>>) -> Receiver<T> { in new_receiver()
658 Receiver { shared, next } in new_receiver()
693 impl<T> Receiver<T> { implementation
[all …]
|
| /external/rust/crates/syn-mid/src/ |
| D | func.rs | 52 Receiver(Receiver),
62 pub struct Receiver {
77 use super::{Block, FnArg, ItemFn, PatType, Receiver, Signature};
146 if let Ok(mut receiver) = ahead.parse::<Receiver>() { in parse()
150 return Ok(FnArg::Receiver(receiver)); in parse()
160 impl Parse for Receiver { implementation
192 use super::{Block, FnArg, ItemFn, Receiver, Signature};
210 FnArg::Receiver(_) => return false, in has_variadic()
255 impl ToTokens for Receiver { implementation
|
| /external/rust/crates/futures-channel/src/ |
| D | oneshot.rs | 20 pub struct Receiver<T> { struct
33 impl<T> Unpin for Receiver<T> {} implementation
107 pub fn channel<T>() -> (Sender<T>, Receiver<T>) { in channel()
109 let receiver = Receiver { in channel()
386 pub fn is_connected_to(&self, receiver: &Receiver<T>) -> bool { in is_connected_to()
428 impl<T> Receiver<T> { impl
453 impl<T> Future for Receiver<T> { implementation
464 impl<T> FusedFuture for Receiver<T> { implementation
479 impl<T> Drop for Receiver<T> { implementation
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | bounded.rs | 43 pub struct Receiver<T> { struct
92 pub fn channel<T>(buffer: usize) -> (Sender<T>, Receiver<T>) { in channel()
98 let rx = Receiver::new(rx); in channel()
107 impl<T> Receiver<T> { impl
108 pub(crate) fn new(chan: chan::Rx<T, Semaphore>) -> Receiver<T> { in new()
109 Receiver { chan } in new()
287 impl<T> fmt::Debug for Receiver<T> { implementation
295 impl<T> Unpin 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
23 pub fn pair<T>() -> (Sender<T>, Receiver<T>) { in pair()
25 let rx = Receiver { _p: PhantomData }; in pair()
69 impl<T> Receiver<T> { implementation
|
| /external/rust/crates/crossbeam-channel/ |
| D | CHANGELOG.md | 5 - Add `Sender::send_deadline()` and `Receiver::recv_deadline()` methods.
49 - Make `size_of::<Receiver<T>>()` smaller.
133 - Implement `IntoIterator<Item = T>` for `Receiver<T>`.
138 - Remove `Sender::is_closed` and `Receiver::is_closed`.
139 - Remove `Sender::close` and `Receiver::close`.
140 - Remove `Sender::send_timeout` and `Receiver::recv_timeout`.
146 - Remove ordering operators for `Sender` and `Receiver`.
150 - Add `Sender::disconnect` and `Receiver::disconnect`.
151 - Implement comparison operators for `Sender` and `Receiver`.
170 - Implement `Debug` for `Sender`, `Receiver`, `Iter`, `TryIter`, `IntoIter`, and `Select`.
|
| /external/llvm-project/clang/lib/DirectoryWatcher/linux/ |
| D | DirectoryWatcher-linux.cpp | 118 std::function<void(llvm::ArrayRef<Event>, bool)> Receiver,
141 std::function<void(llvm::ArrayRef<Event>, bool)> Receiver; member in __anonc2a26de20111::DirectoryWatcherLinux
278 this->Receiver(getAsFileEvents(scanDirectory(WatchedDirPath)), in InitialScan()
285 this->Receiver(Event, false); in EventReceivingLoop()
296 std::function<void(llvm::ArrayRef<Event>, bool)> Receiver, in DirectoryWatcherLinux() argument
300 InotifyWD(InotifyWD), Receiver(Receiver), in DirectoryWatcherLinux()
324 std::function<void(llvm::ArrayRef<DirectoryWatcher::Event>, bool)> Receiver, in create() argument
357 Path, Receiver, WaitForInitialSync, InotifyFD, InotifyWD, in create()
|