| /external/pdfium/core/fxcrt/ |
| D | shared_copy_on_write_unittest.cpp | 34 Object(Observer* observer, const std::string& name) in Object() argument
35 : name_(name), observer_(observer) { in Object()
36 observer->OnConstruct(name_); in Object()
51 Observer observer; in TEST() local
59 Observer observer; in TEST() local
62 ptr1.Emplace(&observer, std::string("one")); in TEST()
65 EXPECT_EQ(1, observer.GetConstructionCount("one")); in TEST()
66 EXPECT_EQ(0, observer.GetDestructionCount("one")); in TEST()
70 EXPECT_EQ(1, observer.GetConstructionCount("one")); in TEST()
71 EXPECT_EQ(0, observer.GetDestructionCount("one")); in TEST()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-subscriber.hpp | 24 template<class T, class Observer = observer<T>>
127 !std::is_same<O, observer<T>>::value && in subscriber()
128 std::is_same<Observer, observer<T>>::value, void**>::type = nullptr) in subscriber()
237 … subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>>>::type { in make_subscriber()
238 …return subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>>(trace… in make_subscriber()
239 … observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>(detail::OnNextEmpty<T>())); in make_subscriber()
244 const observer<T, I>& o) in make_subscriber()
245 -> subscriber<T, observer<T, I>> { in make_subscriber()
246 …return subscriber<T, observer<T, I>>(trace_id::make_next_id_subscriber(), composite_subscriptio… in make_subscriber()
263 subscriber<T, observer<T, Observer>>>::type { in make_subscriber()
[all …]
|
| D | rx-observer.hpp | 179 class observer : public observer_base<T> class
182 using this_type = observer<T, State, OnNext, OnError, OnCompleted>;
205 …explicit observer(state_t s, on_next_t n = on_next_t(), on_error_t e = on_error_t(), on_completed_… in observer() function in rxcpp::observer
212 explicit observer(state_t s, on_next_t n, on_completed_t c) in observer() function in rxcpp::observer
219 observer(const this_type& o) in observer() function in rxcpp::observer
226 observer(this_type&& o) in observer() function in rxcpp::observer
253 observer<T> as_dynamic() const { in as_dynamic()
254 return observer<T>(*this); in as_dynamic()
270 class observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted> : public observer_b… class
273 using this_type = observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>;
[all …]
|
| /external/webrtc/webrtc/call/ |
| D | bitrate_allocator.cc | 56 for (const auto& observer : bitrate_observers_) in AllocateBitrates() local
57 sum_min_bitrates += observer.second.min_bitrate; in AllocateBitrates()
64 int BitrateAllocator::AddBitrateObserver(BitrateObserver* observer, in AddBitrateObserver() argument
70 FindObserverConfigurationPair(observer); in AddBitrateObserver()
84 observer, BitrateConfiguration(min_bitrate_bps, max_bitrate_bps))); in AddBitrateObserver()
92 if (kv.first == observer) in AddBitrateObserver()
98 void BitrateAllocator::RemoveBitrateObserver(BitrateObserver* observer) { in RemoveBitrateObserver() argument
101 FindObserverConfigurationPair(observer); in RemoveBitrateObserver()
114 for (const auto& observer : bitrate_observers_) { in GetMinMaxBitrateSumBps() local
115 *min_bitrate_sum_bps += observer.second.min_bitrate; in GetMinMaxBitrateSumBps()
[all …]
|
| D | bitrate_allocator.h | 47 int AddBitrateObserver(BitrateObserver* observer,
51 void RemoveBitrateObserver(BitrateObserver* observer);
71 ObserverConfiguration(BitrateObserver* observer, uint32_t bitrate) in ObserverConfiguration()
72 : observer(observer), min_bitrate(bitrate) {} in ObserverConfiguration()
73 BitrateObserver* const observer; member
83 const BitrateObserver* observer) EXCLUSIVE_LOCKS_REQUIRED(crit_sect_);
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | ChannelzServiceTest.java | 149 StreamObserver<GetTopChannelsResponse> observer = mock(StreamObserver.class); in getTopChannelHelper() local
154 observer); in getTopChannelHelper() local
155 verify(observer).onNext(responseCaptor.capture()); in getTopChannelHelper()
156 verify(observer).onCompleted(); in getTopChannelHelper()
162 StreamObserver<GetChannelResponse> observer = mock(StreamObserver.class); in getChannelHelper() local
165 service.getChannel(GetChannelRequest.newBuilder().setChannelId(id).build(), observer); in getChannelHelper() local
166 verify(observer).onNext(response.capture()); in getChannelHelper()
167 verify(observer).onCompleted(); in getChannelHelper()
173 StreamObserver<GetChannelResponse> observer = mock(StreamObserver.class); in assertChannelNotFound() local
175 service.getChannel(GetChannelRequest.newBuilder().setChannelId(id).build(), observer); in assertChannelNotFound() local
[all …]
|
| D | HealthStatusManagerTest.java | 62 StreamObserver<HealthCheckResponse> observer = mock(StreamObserver.class); in checkValidStatus() local
65 health.check(request, observer); in checkValidStatus()
68 InOrder inOrder = inOrder(observer); in checkValidStatus()
69 inOrder.verify(observer, times(1)).onNext(any(HealthCheckResponse.class)); in checkValidStatus()
70 inOrder.verify(observer, times(1)).onCompleted(); in checkValidStatus()
71 verify(observer, never()).onError(any(Throwable.class)); in checkValidStatus()
81 StreamObserver<HealthCheckResponse> observer = mock(StreamObserver.class); in checkStatusNotFound() local
84 health.check(request, observer); in checkStatusNotFound()
88 verify(observer, times(1)).onError(exception.capture()); in checkStatusNotFound()
91 verify(observer, never()).onCompleted(); in checkStatusNotFound()
[all …]
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowContentObserverTest.java | 16 private TestContentObserver observer; field in ShadowContentObserverTest
20 observer = new TestContentObserver(null); in setUp()
25 assertThat(observer.changed).isFalse(); in testDispatchChangeBooleanUri()
26 assertThat(observer.selfChange).isFalse(); in testDispatchChangeBooleanUri()
27 assertThat(observer.uri).isNull(); in testDispatchChangeBooleanUri()
30 observer.dispatchChange(true, uri); in testDispatchChangeBooleanUri()
32 assertThat(observer.changed).isTrue(); in testDispatchChangeBooleanUri()
33 assertThat(observer.selfChange).isTrue(); in testDispatchChangeBooleanUri()
34 assertThat(observer.uri).isSameAs(uri); in testDispatchChangeBooleanUri()
39 assertThat(observer.changed).isFalse(); in testDispatchChangeBoolean()
[all …]
|
| /external/setupdesign/main/src/com/google/android/setupdesign/items/ |
| D | AbstractItemHierarchy.java | 59 public void registerObserver(Observer observer) { in registerObserver() argument
60 observers.add(observer); in registerObserver()
64 public void unregisterObserver(Observer observer) { in unregisterObserver() argument
65 observers.remove(observer); in unregisterObserver()
70 for (Observer observer : observers) { in notifyChanged()
71 observer.onChanged(this); in notifyChanged()
86 for (Observer observer : observers) { in notifyItemRangeChanged()
87 observer.onItemRangeChanged(this, position, itemCount); in notifyItemRangeChanged()
102 for (Observer observer : observers) { in notifyItemRangeInserted()
103 observer.onItemRangeInserted(this, position, itemCount); in notifyItemRangeInserted()
[all …]
|
| /external/webrtc/talk/app/webrtc/androidtests/src/org/webrtc/ |
| D | VideoCapturerAndroidTestFixtures.java | 307 final FakeCapturerObserver observer = new FakeCapturerObserver(); in cameraEventsInvoked() local
309 appContext, observer); in cameraEventsInvoked()
311 assertTrue(observer.WaitForCapturerToStart()); in cameraEventsInvoked()
312 observer.WaitForNextCapturedFrame(); in cameraEventsInvoked()
329 final FakeCapturerObserver observer = new FakeCapturerObserver(); in cameraCallsAfterStop() local
331 appContext, observer); in cameraCallsAfterStop()
333 assertTrue(observer.WaitForCapturerToStart()); in cameraCallsAfterStop()
373 FakeCapturerObserver observer = new FakeCapturerObserver(); in startStopWithDifferentResolutions() local
379 appContext, observer); in startStopWithDifferentResolutions()
380 assertTrue(observer.WaitForCapturerToStart()); in startStopWithDifferentResolutions()
[all …]
|
| D | NetworkMonitorTest.java | 202 NetworkMonitorAutoDetect.Observer observer = new TestNetworkMonitorAutoDetectObserver(); in testNetworkMonitorRegistersInConstructor() local
204 NetworkMonitorAutoDetect receiver = new NetworkMonitorAutoDetect(observer, context); in testNetworkMonitorRegistersInConstructor()
221 NetworkMonitorTestObserver observer = new NetworkMonitorTestObserver(); in testNetworkMonitorJavaObservers() local
222 NetworkMonitor.addNetworkObserver(observer); in testNetworkMonitorJavaObservers()
224 assertFalse(observer.hasReceivedNotification()); in testNetworkMonitorJavaObservers()
229 assertFalse(observer.hasReceivedNotification()); in testNetworkMonitorJavaObservers()
234 assertTrue(observer.hasReceivedNotification()); in testNetworkMonitorJavaObservers()
235 observer.resetHasReceivedNotification(); in testNetworkMonitorJavaObservers()
240 assertTrue(observer.hasReceivedNotification()); in testNetworkMonitorJavaObservers()
241 observer.resetHasReceivedNotification(); in testNetworkMonitorJavaObservers()
[all …]
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowBackupManager.java | 103 public int getAvailableRestoreSets(IRestoreObserver observer) throws RemoteException { in getAvailableRestoreSets() argument
104 return getAvailableRestoreSets(observer, null); in getAvailableRestoreSets()
108 public int getAvailableRestoreSets(IRestoreObserver observer, IBackupManagerMonitor monitor) in getAvailableRestoreSets() argument
117 observer.restoreSetsAvailable(restoreSets.toArray(new RestoreSet[restoreSets.size()])); in getAvailableRestoreSets()
123 public int restoreAll(long token, IRestoreObserver observer) throws RemoteException { in restoreAll() argument
124 return restoreAll(token, observer, null); in restoreAll()
128 public int restoreAll(long token, IRestoreObserver observer, IBackupManagerMonitor monitor) in restoreAll() argument
130 return restorePackages(token, observer, null, monitor); in restoreAll()
134 public int restoreSome(long token, IRestoreObserver observer, String[] packages) in restoreSome() argument
136 return restorePackages(token, observer, packages, null); in restoreSome()
[all …]
|
| /external/mockito/src/test/java/org/mockito/internal/util/reflection/ |
| D | ParameterizedConstructorInstantiatorTest.java | 71 Observer observer = mock(Observer.class); in should_instantiate_type_if_resolver_provide_matching_types() local
73 ….resolveTypeInstances(Matchers.<Class<?>[]>anyVararg())).willReturn(new Object[]{ observer, map }); in should_instantiate_type_if_resolver_provide_matching_types()
78 assertNotNull(withMultipleConstructor.observer); in should_instantiate_type_if_resolver_provide_matching_types()
84 Observer observer = mock(Observer.class); in should_fail_if_an_argument_instance_type_do_not_match_wanted_type() local
86 …lveTypeInstances(Matchers.<Class<?>[]>anyVararg())).willReturn(new Object[]{ observer, wrongArg }); in should_fail_if_an_argument_instance_type_do_not_match_wanted_type()
129 public OneConstructor(Observer observer) { } in OneConstructor() argument
133 … public ThrowingConstructor(Observer observer) throws IOException { throw new IOException(); } in ThrowingConstructor() argument
137 Observer observer; field in ParameterizedConstructorInstantiatorTest.MultipleConstructor
140 public MultipleConstructor(Observer observer) { this(observer, null); } in MultipleConstructor() argument
141 public MultipleConstructor(Observer observer, Map map) { in MultipleConstructor() argument
[all …]
|
| /external/skqp/modules/skottie/src/ |
| D | SkottieTest.cpp | 116 auto observer = sk_make_sp<TestPropertyObserver>(); in DEF_TEST() local
119 .setPropertyObserver(observer) in DEF_TEST()
124 const auto& colors = observer->colors(); in DEF_TEST()
129 const auto& opacities = observer->opacities(); in DEF_TEST()
136 const auto& transforms = observer->transforms(); in DEF_TEST()
204 auto observer = sk_make_sp<TestMarkerObserver>(); in DEF_TEST() local
207 .setMarkerObserver(observer) in DEF_TEST()
212 REPORTER_ASSERT(reporter, observer->fMarkers.size() == 2ul); in DEF_TEST()
213 REPORTER_ASSERT(reporter, std::get<0>(observer->fMarkers[0]) == "marker_1"); in DEF_TEST()
214 REPORTER_ASSERT(reporter, std::get<1>(observer->fMarkers[0]) == 0.25f); in DEF_TEST()
[all …]
|
| /external/skia/modules/skottie/src/ |
| D | SkottieTest.cpp | 116 auto observer = sk_make_sp<TestPropertyObserver>(); in DEF_TEST() local
119 .setPropertyObserver(observer) in DEF_TEST()
124 const auto& colors = observer->colors(); in DEF_TEST()
129 const auto& opacities = observer->opacities(); in DEF_TEST()
136 const auto& transforms = observer->transforms(); in DEF_TEST()
204 auto observer = sk_make_sp<TestMarkerObserver>(); in DEF_TEST() local
207 .setMarkerObserver(observer) in DEF_TEST()
212 REPORTER_ASSERT(reporter, observer->fMarkers.size() == 2ul); in DEF_TEST()
213 REPORTER_ASSERT(reporter, std::get<0>(observer->fMarkers[0]) == "marker_1"); in DEF_TEST()
214 REPORTER_ASSERT(reporter, std::get<1>(observer->fMarkers[0]) == 0.25f); in DEF_TEST()
[all …]
|
| /external/webrtc/talk/app/webrtc/ |
| D | webrtcsessiondescriptionfactory.cc | 78 webrtc::CreateSessionDescriptionObserver* observer) in CreateSessionDescriptionMsg()
79 : observer(observer) { in CreateSessionDescriptionMsg()
82 rtc::scoped_refptr<webrtc::CreateSessionDescriptionObserver> observer; member
257 CreateSessionDescriptionObserver* observer, in CreateOffer() argument
264 PostCreateSessionDescriptionFailed(observer, error); in CreateOffer()
271 PostCreateSessionDescriptionFailed(observer, error); in CreateOffer()
276 CreateSessionDescriptionRequest::kOffer, observer, session_options); in CreateOffer()
287 CreateSessionDescriptionObserver* observer, in CreateAnswer() argument
294 PostCreateSessionDescriptionFailed(observer, error); in CreateAnswer()
300 PostCreateSessionDescriptionFailed(observer, error); in CreateAnswer()
[all …]
|
| D | dtlsidentitystore.cc | 143 const rtc::scoped_refptr<webrtc::DtlsIdentityRequestObserver>& observer) { in RequestIdentity() argument
145 RTC_DCHECK(observer); in RequestIdentity()
147 GenerateIdentity(key_type, observer); in RequestIdentity()
171 const rtc::scoped_refptr<webrtc::DtlsIdentityRequestObserver>& observer) { in GenerateIdentity() argument
175 if (observer.get()) { in GenerateIdentity()
176 request_info_[key_type].request_observers_.push(observer); in GenerateIdentity()
215 rtc::scoped_refptr<webrtc::DtlsIdentityRequestObserver> observer; in OnIdentityGenerated() local
217 observer = request_info_[key_type].request_observers_.front(); in OnIdentityGenerated()
221 if (observer.get() == nullptr) { in OnIdentityGenerated()
233 observer->OnSuccess(std::move(identity)); in OnIdentityGenerated()
[all …]
|
| D | remoteaudiosource.cc | 116 for (auto* observer : audio_observers_) in SetVolume() local
117 observer->OnSetVolume(volume); in SetVolume()
120 void RemoteAudioSource::RegisterAudioObserver(AudioObserver* observer) { in RegisterAudioObserver() argument
121 RTC_DCHECK(observer != NULL); in RegisterAudioObserver()
123 observer) == audio_observers_.end()); in RegisterAudioObserver()
124 audio_observers_.push_back(observer); in RegisterAudioObserver()
127 void RemoteAudioSource::UnregisterAudioObserver(AudioObserver* observer) { in UnregisterAudioObserver() argument
128 RTC_DCHECK(observer != NULL); in UnregisterAudioObserver()
129 audio_observers_.remove(observer); in UnregisterAudioObserver()
|
| D | peerconnection.cc | 110 webrtc::SetSessionDescriptionObserver* observer) in SetSessionDescriptionMsg()
111 : observer(observer) { in SetSessionDescriptionMsg()
114 rtc::scoped_refptr<webrtc::SetSessionDescriptionObserver> observer; member
120 webrtc::CreateSessionDescriptionObserver* observer) in CreateSessionDescriptionMsg()
121 : observer(observer) {} in CreateSessionDescriptionMsg()
123 rtc::scoped_refptr<webrtc::CreateSessionDescriptionObserver> observer; member
128 GetStatsMsg(webrtc::StatsObserver* observer, in GetStatsMsg()
130 : observer(observer), track(track) { in GetStatsMsg()
132 rtc::scoped_refptr<webrtc::StatsObserver> observer; member
593 PeerConnectionObserver* observer) { in Initialize() argument
[all …]
|
| /external/libchrome/base/ |
| D | observer_list_threadsafe.h | 106 void AddObserver(ObserverType* observer) {
115 DCHECK(!ContainsKey(observers_, observer));
118 observers_[observer] = task_runner;
133 observer,
144 void RemoveObserver(ObserverType* observer) {
146 observers_.erase(observer);
168 for (const auto& observer : observers_) {
169 observer.second->PostTask(
172 observer.first, NotificationData(this, from_here, method)));
191 void NotifyWrapper(ObserverType* observer,
[all …]
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/ |
| D | EventFacade.java | 225 EventObserver observer; in eventWait() local
230 observer = new EventObserver() { in eventWait()
242 addGlobalEventObserver(observer); in eventWait()
253 Log.v(String.format("Removing observer (%s) got event (%s)", observer, result)); in eventWait()
254 if (observer != null) { in eventWait()
255 removeEventObserver(observer); // Make quite sure this goes away. in eventWait()
324 for (EventObserver observer : mNamedEventObservers.get(event.getName())) { in postEventToNamedObservers()
326 observer, in postEventToNamedObservers()
328 observer.onEventReceived(event); in postEventToNamedObservers()
338 for (EventObserver observer : mGlobalEventObservers) { in postEventToGlobalObservers()
[all …]
|
| /external/webrtc/talk/app/webrtc/java/android/org/webrtc/ |
| D | NetworkMonitor.java | 179 for (NetworkObserver observer : networkObservers) { in notifyObserversOfConnectionTypeChange()
180 observer.onConnectionTypeChanged(newConnectionType); in notifyObserversOfConnectionTypeChange()
187 public static void addNetworkObserver(NetworkObserver observer) { in addNetworkObserver() argument
188 getInstance().addNetworkObserverInternal(observer); in addNetworkObserver()
191 private void addNetworkObserverInternal(NetworkObserver observer) { in addNetworkObserverInternal() argument
192 networkObservers.add(observer); in addNetworkObserverInternal()
198 public static void removeNetworkObserver(NetworkObserver observer) { in removeNetworkObserver() argument
199 getInstance().removeNetworkObserverInternal(observer); in removeNetworkObserver()
202 private void removeNetworkObserverInternal(NetworkObserver observer) { in removeNetworkObserverInternal() argument
203 networkObservers.remove(observer); in removeNetworkObserverInternal()
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/trigger/ |
| D | TriggerRepository.java | 120 for (TriggerRepositoryObserver observer : mTriggerObservers) { in notifyOnAdd()
121 observer.onPut(trigger); in notifyOnAdd()
127 for (TriggerRepositoryObserver observer : mTriggerObservers) { in notifyOnRemove()
128 observer.onRemove(trigger); in notifyOnRemove()
178 public void addObserver(TriggerRepositoryObserver observer) { in addObserver() argument
179 mTriggerObservers.add(observer); in addObserver()
189 public synchronized void bootstrapObserver(TriggerRepositoryObserver observer) { in bootstrapObserver() argument
190 addObserver(observer); in bootstrapObserver()
192 observer.onPut(trigger.getValue()); in bootstrapObserver()
199 public void removeObserver(TriggerRepositoryObserver observer) { in removeObserver() argument
[all …]
|
| /external/libchrome/device/bluetooth/ |
| D | bluetooth_advertisement.cc | 20 BluetoothAdvertisement::Observer* observer) { in AddObserver() argument
21 CHECK(observer); in AddObserver()
22 observers_.AddObserver(observer); in AddObserver()
26 BluetoothAdvertisement::Observer* observer) { in RemoveObserver() argument
27 CHECK(observer); in RemoveObserver()
28 observers_.RemoveObserver(observer); in RemoveObserver()
|
| /external/sl4a/Utils/src/com/googlecode/android_scripting/ |
| D | SimpleServer.java | 63 public void addObserver(SimpleServerObserver observer) { in addObserver() argument
64 mObservers.add(observer); in addObserver()
70 public void removeObserver(SimpleServerObserver observer) { in removeObserver() argument
71 mObservers.remove(observer); in removeObserver()
79 for (SimpleServerObserver observer : mObservers) { in notifyOnConnect()
80 observer.onConnect(); in notifyOnConnect()
86 for (SimpleServerObserver observer : mObservers) { in notifyOnDisconnect()
87 observer.onDisconnect(); in notifyOnDisconnect()
310 for (SimpleServerObserver observer : mObservers) { in shutdown()
311 removeObserver(observer); in shutdown()
|