| /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/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/apps/Launcher3/quickstep/src/com/android/quickstep/ |
| D | TouchInteractionService.java | 312 private @NonNull InputConsumer mConsumer = InputConsumer.NO_OP; field in TouchInteractionService
545 mConsumer.onConsumerAboutToBeSwitched(); in onInputEvent()
547 mConsumer = newConsumer(prevGestureState, mGestureState, event); in onInputEvent()
549 ActiveGestureLog.INSTANCE.addLog("setInputConsumer: " + mConsumer.getName()); in onInputEvent()
550 mUncheckedConsumer = mConsumer; in onInputEvent()
603 && mConsumer != null in onInputEvent()
604 && !mConsumer.getActiveConsumerInHierarchy().isConsumerDetachedFromGesture(); in onInputEvent()
816 if (mConsumer != null && mConsumer.getActiveConsumerInHierarchy() == caller) { in onConsumerInactive()
822 mConsumer = mUncheckedConsumer = getDefaultInputConsumer(); in reset()
938 pw.println(" mConsumer=" + mConsumer.getName()); in dump()
[all …]
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/ |
| D | QueryTask.java | 38 private final Consumer<C> mConsumer; field in QueryTask
56 mConsumer = consumer; in QueryTask()
68 Consumers.consumeCloseableAsync(mHandler, mConsumer, cursor); in run()
|
| /packages/modules/NetworkStack/tests/unit/src/android/net/ip/ |
| D | ConntrackMonitorTest.java | 72 @Mock private ConntrackMonitor.ConntrackEventConsumer mConsumer; field in ConntrackMonitorTest
127 TestConntrackMonitor m = new TestConntrackMonitor(mHandler, mLog, mConsumer); in setUp()
222 verify(mConsumer, timeout(TIMEOUT_MS)).accept(eq(expectedEvent)); in testConntrackEventNew()
332 verify(mConsumer, timeout(TIMEOUT_MS)).accept(eq(expectedEvent)); in testConntrackEventDelete()
|
| /packages/modules/NetworkStack/common/moduleutils/src/android/net/ip/ |
| D | ConntrackMonitor.java | 174 private final ConntrackEventConsumer mConsumer; field in ConntrackMonitor
180 mConsumer = cb; in ConntrackMonitor()
196 mConsumer.accept(new ConntrackEvent(conntrackMsg)); in processNetlinkMessage()
|
| D | IpNeighborMonitor.java | 123 private final NeighborEventConsumer mConsumer; field in IpNeighborMonitor
127 mConsumer = (cb != null) ? cb : (event) -> { /* discard */ }; in IpNeighborMonitor()
163 mConsumer.accept(event); in processNetlinkMessage()
|
| /packages/modules/IPsec/src/java/com/android/internal/net/ipsec/ike/ |
| D | IkeLocalRequestScheduler.java | 91 private final IProcedureConsumer mConsumer; field in IkeLocalRequestScheduler
101 mConsumer = consumer; in IkeLocalRequestScheduler()
123 mConsumer.onNewProcedureReady(mRequestQueue.poll()); in readyForNextProcedure()
|
| /packages/modules/Connectivity/Tethering/tests/unit/src/com/android/networkstack/tethering/ |
| D | BpfCoordinatorTest.java | 228 private BpfConntrackEventConsumer mConsumer; field in BpfCoordinatorTest
329 mConsumer = coordinator.getBpfConntrackEventConsumerForTesting(); in makeBpfCoordinator()
1462 mConsumer.accept(makeTestConntrackEvent(IPCTNL_MSG_CT_NEW, IPPROTO_TCP)); in testSetDataLimitOnRule4Change()
1471 mConsumer.accept(makeTestConntrackEvent(IPCTNL_MSG_CT_NEW, IPPROTO_UDP)); in testSetDataLimitOnRule4Change()
1480 mConsumer.accept(makeTestConntrackEvent(IPCTNL_MSG_CT_DELETE, IPPROTO_UDP)); in testSetDataLimitOnRule4Change()
1489 mConsumer.accept(makeTestConntrackEvent(IPCTNL_MSG_CT_DELETE, IPPROTO_TCP)); in testSetDataLimitOnRule4Change()
1522 mConsumer.accept(makeTestConntrackEvent(IPCTNL_MSG_CT_NEW, IPPROTO_TCP)); in testAddDevMapRule4()
1529 mConsumer.accept(makeTestConntrackEvent(IPCTNL_MSG_CT_NEW, IPPROTO_UDP)); in testAddDevMapRule4()
|