Searched refs:mConsumer (Results 1 – 7 of 7) sorted by relevance
31 private Consumer<MotionEvent> mConsumer; field in CachedEventDispatcher37 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()
40 private TestConsumer<String> mConsumer; field in PreferencesMonitorTest44 mConsumer = new TestConsumer<>(); in setUp()46 mMonitor = new PreferencesMonitor("Poodles", mPrefs, mConsumer); in setUp()59 mConsumer.waitForCall(100, TimeUnit.MILLISECONDS); in testReportsChangesToListener()60 mConsumer.assertLastArgument(ScopedPreferences.INCLUDE_DEVICE_ROOT); in testReportsChangesToListener()
26 private volatile Buffer mConsumer = null; field in SharedBuffer50 return mConsumer; in getConsumer()65 mIntermediate = mConsumer; in swapConsumerIfNeeded()66 mConsumer = intermediate; in swapConsumerIfNeeded()
292 private InputConsumer mConsumer = InputConsumer.NO_OP; field in TouchInteractionService555 boolean useSharedState = mConsumer.useSharedSwipeState(); in onInputEvent()556 mConsumer.onConsumerAboutToBeSwitched(); in onInputEvent()557 mConsumer = newConsumer(useSharedState, event); in onInputEvent()558 TOUCH_INTERACTION_LOG.addLog("setInputConsumer", mConsumer.getType()); in onInputEvent()559 mUncheckedConsumer = mConsumer; in onInputEvent()755 if (mConsumer == caller) { in onConsumerInactive()756 mConsumer = mResetGestureInputConsumer; in onConsumerInactive()757 mUncheckedConsumer = mConsumer; in onConsumerInactive()843 pw.println(" useSharedState=" + mConsumer.useSharedSwipeState()); in dump()[all …]
38 private final Consumer<C> mConsumer; field in QueryTask56 mConsumer = consumer; in QueryTask()68 Consumers.consumeCloseableAsync(mHandler, mConsumer, cursor); in run()
53 private final IProcedureConsumer mConsumer; field in IkeLocalRequestScheduler61 mConsumer = consumer; in IkeLocalRequestScheduler()86 mConsumer.onNewProcedureReady(mRequestQueue.poll()); in readyForNextProcedure()
123 private final NeighborEventConsumer mConsumer; field in IpNeighborMonitor127 mConsumer = (cb != null) ? cb : (event) -> { /* discard */ }; in IpNeighborMonitor()163 mConsumer.accept(event); in processNetlinkMessage()