Searched refs:addDataSubscriber (Results 1 – 13 of 13) sorted by relevance
185 mPublisher.addDataSubscriber(mMockDataSubscriber); in testAddDataSubscriber_whenNoPackageName_pullsDeviceMeminfo()204 mPublisher.addDataSubscriber(dataSubscriber); in testAddDataSubscriber_whenMatchingPackageName_pullsDeviceAndProcessMeminfo()250 mPublisher.addDataSubscriber(dataSubscriber); in testAddDataSubscriber_multipleMatchingPackageName_pullsDeviceAndProcessMeminfo()306 mPublisher.addDataSubscriber(dataSubscriber); in testAddDataSubscriber_whenPackageNameNotFound_doesNotPullProcessMeminfo()320 mPublisher.addDataSubscriber(mMockDataSubscriber); in testAddDataSubscriber_annotatesWithDrivingSessionData()331 mPublisher.addDataSubscriber(mMockDataSubscriber); in testAddDataSubscriber_whenDataSubscriberAlreadyExists_throwsException()334 () -> mPublisher.addDataSubscriber(mMockDataSubscriber)); in testAddDataSubscriber_whenDataSubscriberAlreadyExists_throwsException()353 () -> mPublisher.addDataSubscriber(mockDataSubscriber1)); in testAddDataSubscriber_whenConfigHasIllegalFields_throwsException()355 () -> mPublisher.addDataSubscriber(mockDataSubscriber2)); in testAddDataSubscriber_whenConfigHasIllegalFields_throwsException()360 mPublisher.addDataSubscriber(mMockDataSubscriber); in testAddDataSubscriber_schedulesNextPullBasedOnReadRate()[all …]
135 mPublisher.addDataSubscriber(mMockDataSubscriber); in testAddDataSubscriber_registersNewListener()153 () -> mPublisher.addDataSubscriber(invalidDataSubscriber)); in testAddDataSubscriber_withInvalidId_fails()170 mPublisher.addDataSubscriber(mMockDataSubscriber); in testRemoveDataSubscriber_removesOnlySingleSubscriber()171 mPublisher.addDataSubscriber(subscriber2); in testRemoveDataSubscriber_removesOnlySingleSubscriber()182 mPublisher.addDataSubscriber(mMockDataSubscriber); in testRemoveDataSubscriber_disconnectsFromICarTelemetry()194 mPublisher.addDataSubscriber(mMockDataSubscriber); in testRemoveAllDataSubscribers_succeeds()195 mPublisher.addDataSubscriber(subscriber2); in testRemoveAllDataSubscribers_succeeds()206 mPublisher.addDataSubscriber(mMockDataSubscriber); in testNotifiesFailureConsumer_whenBinderDies()220 mPublisher.addDataSubscriber(mMockDataSubscriber); in testNotifiesFailureConsumer_whenFailsConnectToService()229 mPublisher.addDataSubscriber(mMockDataSubscriber); in testPushesPublishedData_whenOnCarDataReceived()[all …]
329 mVehiclePropertyPublisher.addDataSubscriber(mMockIntDataSubscriber); in testAddDataSubscriber_registersNewCallback()341 mVehiclePropertyPublisher.addDataSubscriber(mMockIntDataSubscriber); in testAddDataSubscriber_withSamePropertyId_registersSingleListener()342 mVehiclePropertyPublisher.addDataSubscriber(subscriber2); in testAddDataSubscriber_withSamePropertyId_registersSingleListener()361 () -> mVehiclePropertyPublisher.addDataSubscriber(invalidDataSubscriber)); in testAddDataSubscriber_failsIfInvalidCarProperty()373 () -> mVehiclePropertyPublisher.addDataSubscriber(invalidDataSubscriber)); in testAddDataSubscriber_failsIfNoReadAccess()381 mVehiclePropertyPublisher.addDataSubscriber(mMockIntDataSubscriber); in testRemoveDataSubscriber_succeeds()398 mVehiclePropertyPublisher.addDataSubscriber(mMockIntDataSubscriber); in testRemoveAllDataSubscribers_succeeds()399 mVehiclePropertyPublisher.addDataSubscriber(subscriber2); in testRemoveAllDataSubscribers_succeeds()413 mVehiclePropertyPublisher.addDataSubscriber(mMockIntDataSubscriber); in testOnNewCarPropertyEvent_pushesValueToDataSubscriber()430 mVehiclePropertyPublisher.addDataSubscriber(mMockStringDataSubscriber); in testOnNewCarPropertyEvent_parsesValueCorrectly()[all …]
292 mPublisher.addDataSubscriber(DATA_SUBSCRIBER_1); in testAddDataSubscriber_registersNewListener()301 mPublisher.addDataSubscriber(DATA_SUBSCRIBER_1); in testAddDataSubscriber_sameVersion_addsToStatsdOnce()302 mPublisher.addDataSubscriber(DATA_SUBSCRIBER_1); in testAddDataSubscriber_sameVersion_addsToStatsdOnce()311 mPublisher.addDataSubscriber(DATA_SUBSCRIBER_1); in testAddDataSubscriber_whenRestarted_addsToStatsdOnce()314 publisher2.addDataSubscriber(DATA_SUBSCRIBER_1); in testAddDataSubscriber_whenRestarted_addsToStatsdOnce()327 mPublisher.addDataSubscriber(processMemoryStateSubscriber); in testAddDataSubscriber_forProcessMemoryState_generatesStatsdMetrics()340 mPublisher.addDataSubscriber(activityForegroundStateSubscriber); in testAddDataSubscriber_forActivityForegroundState_generatesStatsdMetrics()349 mPublisher.addDataSubscriber(DATA_SUBSCRIBER_1); in testRemoveDataSubscriber_removesFromStatsd()373 mPublisher.addDataSubscriber(DATA_SUBSCRIBER_1); in testRemoveAllDataSubscriber_whenRestarted_removesFromStatsdAndClears()386 mPublisher.addDataSubscriber(DATA_SUBSCRIBER_1); in testAddDataSubscriber_queuesPeriodicTaskInTheHandler()[all …]
205 mPublisher.addDataSubscriber(mDataSubscriberWifi); in testAddDataSubscriber_storesIt()212 mPublisher.addDataSubscriber(mDataSubscriberWifi); in testRemoveDataSubscriber_removesIt()213 mPublisher.addDataSubscriber(mDataSubscriberCell); in testRemoveDataSubscriber_removesIt()222 mPublisher.addDataSubscriber(mDataSubscriberWifi); in testRemoveDataSubscriber_givenWrongSubscriber_doesNothing()231 mPublisher.addDataSubscriber(mDataSubscriberWifi); in testRemoveAllDataSubscribers_removesAll()232 mPublisher.addDataSubscriber(mDataSubscriberCell); in testRemoveAllDataSubscribers_removesAll()244 mPublisher.addDataSubscriber(mDataSubscriberWifi); in testPullsOnlyNecessaryData()262 mPublisher.addDataSubscriber(mDataSubscriberWifi); in testPullsOnlyNecessaryData_wifiAndMobile()263 mPublisher.addDataSubscriber(mDataSubscriberCell); in testPullsOnlyNecessaryData_wifiAndMobile()285 mPublisher.addDataSubscriber(mDataSubscriberCell); in testPullsTaggedAndUntaggedMobileStats()[all …]
82 public abstract void addDataSubscriber(@NonNull DataSubscriber subscriber); in addDataSubscriber() method in AbstractPublisher
200 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber() method in CarTelemetrydPublisher
145 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber() method in MemoryPublisher
143 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber() method in ConnectivityPublisher
101 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber() method in VehiclePropertyPublisher
218 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber() method in StatsPublisher
330 publisher.addDataSubscriber(dataSubscriber); in addMetricsConfig()
642 doThrow(new IllegalArgumentException()).when(mAbstractPublisher).addDataSubscriber(any()); in testAddMetricsConfig_whenPublisherThrowsException_shouldRelayException()