| /packages/apps/Launcher3/quickstep/src/com/android/quickstep/util/ |
| D | CachedEventDispatcher.java | 31 private Consumer<MotionEvent> mConsumer; field in CachedEventDispatcher
37 if (mConsumer != null) { in dispatchEvent()
38 mConsumer.accept(event); in dispatchEvent()
55 mConsumer = consumer; in setConsumer()
59 mConsumer.accept(ev); in setConsumer()
67 return mConsumer != null; in hasConsumer()
|
| /packages/apps/DocumentsUI/tests/unit/com/android/documentsui/prefs/ |
| D | PreferencesMonitorTest.java | 42 private TestConsumer<String> mConsumer; field in PreferencesMonitorTest
46 mConsumer = new TestConsumer<>(); in setUp()
48 mMonitor = new PreferencesMonitor("Poodles", mPrefs, mConsumer); in setUp()
61 mConsumer.waitForCall(100, TimeUnit.MILLISECONDS); in testReportsChangesToListener()
62 mConsumer.assertLastArgument(LOCAL_PREFERENCE); in testReportsChangesToListener()
|
| /packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/data/measurement/ |
| D | SQLDatastoreManagerTest.java | 54 @Mock private DatastoreManager.ThrowingCheckedConsumer mConsumer; field in SQLDatastoreManagerTest
160 doThrow(new IllegalArgumentException()).when(mConsumer).accept(any()); in runInTransaction_throwsException_logsDbVersion()
165 () -> mSQLDatastoreManager.runInTransaction(mConsumer)); in runInTransaction_throwsException_logsDbVersion()
184 doThrow(new DatastoreException(null)).when(mConsumer).accept(any()); in runInTransaction_throwsDataStoreExceptionExceptionDisable_logsDbVersion()
189 mSQLDatastoreManager.runInTransaction(mConsumer); in runInTransaction_throwsDataStoreExceptionExceptionDisable_logsDbVersion()
209 doThrow(new DatastoreException(null)).when(mConsumer).accept(any()); in runInTransaction_throwsDataStoreExceptionSamplingDisabled_logsDbVersion()
215 mSQLDatastoreManager.runInTransaction(mConsumer); in runInTransaction_throwsDataStoreExceptionSamplingDisabled_logsDbVersion()
235 doThrow(new DatastoreException(null)).when(mConsumer).accept(any()); in runInTransaction_throwsDataStoreExceptionExceptionEnable_logsDbVersion()
242 mSQLDatastoreManager.runInTransaction(mConsumer); in runInTransaction_throwsDataStoreExceptionExceptionEnable_logsDbVersion()
|
| /packages/apps/Gallery2/src/com/android/gallery3d/filtershow/pipeline/ |
| D | SharedBuffer.java | 26 private volatile Buffer mConsumer = null; field in SharedBuffer
50 return mConsumer; in getConsumer()
65 mIntermediate = mConsumer; in swapConsumerIfNeeded()
66 mConsumer = intermediate; in swapConsumerIfNeeded()
|
| /packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/common/ |
| D | AdservicesSyncUtilTest.java | 34 @Mock BiConsumer<Context, Boolean> mConsumer; field in AdservicesSyncUtilTest
41 doNothing().when(mConsumer).accept(any(Context.class), any(Boolean.class)); in setup()
46 mAdservicesSyncUtil.register(mConsumer); in testRegisterConsumerAndExecute()
48 verify(mConsumer).accept(mContext, true); in testRegisterConsumerAndExecute()
|
| /packages/apps/ManagedProvisioning/tests/instrumentation/src/com/android/managedprovisioning/task/ |
| D | MockTask.java | 31 private final Consumer<AbstractProvisioningTask> mConsumer; field in MockTask
43 mConsumer = requireNonNull(consumer); in MockTask()
48 mConsumer.accept(this); in run()
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/ |
| D | QueryTask.kt | 36 private val mConsumer: Consumer<C>? constant
46 Consumers.consumeCloseableAsync(mHandler, mConsumer, cursor) in run()
84 mConsumer = consumer
|
| /packages/modules/Connectivity/staticlibs/device/com/android/net/module/util/ip/ |
| D | ConntrackMonitor.java | 179 private final ConntrackEventConsumer mConsumer; field in ConntrackMonitor
185 mConsumer = cb; in ConntrackMonitor()
201 mConsumer.accept(new ConntrackEvent(conntrackMsg)); in processNetlinkMessage()
|
| D | IpNeighborMonitor.java | 138 private final NeighborEventConsumer mConsumer; field in IpNeighborMonitor
142 mConsumer = (cb != null) ? cb : (event) -> { /* discard */ }; in IpNeighborMonitor()
178 mConsumer.accept(event); in processNetlinkMessage()
|
| /packages/modules/Connectivity/staticlibs/tests/unit/src/com/android/net/module/util/ip/ |
| D | ConntrackMonitorTest.java | 74 @Mock private ConntrackMonitor.ConntrackEventConsumer mConsumer; field in ConntrackMonitorTest
129 TestConntrackMonitor m = new TestConntrackMonitor(mHandler, mLog, mConsumer); in setUp()
224 verify(mConsumer, timeout(TIMEOUT_MS)).accept(eq(expectedEvent)); in testConntrackEventNew()
334 verify(mConsumer, timeout(TIMEOUT_MS)).accept(eq(expectedEvent)); in testConntrackEventDelete()
|
| /packages/apps/Settings/src/com/android/settings/accessibility/ |
| D | ScreenFlashNotificationColorDialogFragment.java | 58 private Consumer<Integer> mConsumer; field in ScreenFlashNotificationColorDialogFragment
68 result.mConsumer = colorConsumer != null ? colorConsumer : i -> { in getInstance()
94 mConsumer.accept(mCurrentColor); in onCreateDialog()
|
| /packages/apps/Car/Launcher/libs/appgrid/lib/tests/src/com/android/car/carlauncher/ |
| D | LauncherViewModelTest.java | 53 private Consumer mConsumer = mock(Consumer.class); field in LauncherViewModelTest
89 mDrawable, true, false, true, mConsumer, mConsumer); in createTestAppMetaData()
|
| /packages/modules/IPsec/src/java/com/android/internal/net/ipsec/ike/ |
| D | IkeLocalRequestScheduler.java | 95 private final IProcedureConsumer mConsumer; field in IkeLocalRequestScheduler
105 mConsumer = consumer; in IkeLocalRequestScheduler()
127 mConsumer.onNewProcedureReady(mRequestQueue.poll()); in readyForNextProcedure()
|
| /packages/modules/Connectivity/nearby/framework/java/android/nearby/ |
| D | NearbyManager.java | 348 volatile @Nullable Consumer<OffloadCapability> mConsumer; field in NearbyManager.OffloadTransport
354 mConsumer = consumer; in OffloadTransport()
360 if (mConsumer != null) { in onQueryComplete()
361 mConsumer.accept(capability); in onQueryComplete()
|
| /packages/apps/Launcher3/quickstep/src/com/android/quickstep/ |
| D | TouchInteractionService.java | 560 private @NonNull InputConsumer mConsumer = InputConsumer.NO_OP; field in TouchInteractionService
846 mConsumer.onConsumerAboutToBeSwitched();
848 mConsumer = newConsumer(prevGestureState, mGestureState, event);
849 mUncheckedConsumer = mConsumer;
925 && mConsumer != null
926 && !mConsumer.getActiveConsumerInHierarchy().isConsumerDetachedFromGesture();
1399 if (mConsumer != null && mConsumer.getActiveConsumerInHierarchy() == caller) {
1405 mConsumer = mUncheckedConsumer = getDefaultInputConsumer();
1538 pw.println("\tmConsumer=" + mConsumer.getName());
|
| /packages/modules/Connectivity/Tethering/tests/unit/src/com/android/networkstack/tethering/ |
| D | BpfCoordinatorTest.java | 466 private BpfConntrackEventConsumer mConsumer; field in BpfCoordinatorTest
671 mConsumer = coordinator.getBpfConntrackEventConsumerForTesting(); in makeBpfCoordinator()
1968 mConsumer.accept(new TestConntrackEvent.Builder() in testSetDataLimitOnRule4Change()
1980 mConsumer.accept(new TestConntrackEvent.Builder() in testSetDataLimitOnRule4Change()
1992 mConsumer.accept(new TestConntrackEvent.Builder() in testSetDataLimitOnRule4Change()
2004 mConsumer.accept(new TestConntrackEvent.Builder() in testSetDataLimitOnRule4Change()
2044 mConsumer.accept(new TestConntrackEvent.Builder() in testAddDevMapRule4()
2054 mConsumer.accept(new TestConntrackEvent.Builder() in testAddDevMapRule4()
2170 mConsumer.accept(new TestConntrackEvent.Builder() in testNotAllowOffloadByConntrackMessageDestinationPort()
2180 mConsumer.accept(new TestConntrackEvent.Builder() in testNotAllowOffloadByConntrackMessageDestinationPort()
[all …]
|
| /packages/services/Telephony/src/com/android/phone/ |
| D | PhoneInterfaceManager.java | 14145 private final Consumer<Integer> mConsumer; field in PhoneInterfaceManager.CallerCallbackInfo
14149 mConsumer = consumer; in CallerCallbackInfo()
14154 return mConsumer; in getConsumer()
|