/packages/apps/DocumentsUI/tests/functional/com/android/documentsui/inspector/ |
D | DocumentLoaderTest.java | 102 LatchedConsumer<DocumentInfo> consumer = new LatchedConsumer<>(1); in testLoadsDocument() local 103 mLoader.loadDocInfo(validUri, mUserId, consumer); in testLoadsDocument() 108 consumer.assertCalled(1000, TimeUnit.MILLISECONDS); in testLoadsDocument() 110 assertNotNull(consumer.getValue()); in testLoadsDocument() 111 assertEquals(consumer.getValue().displayName, TEST_DOC_NAME); in testLoadsDocument() 112 assertEquals(consumer.getValue().size, 0); in testLoadsDocument() 121 LatchedConsumer<DocumentInfo> consumer = new LatchedConsumer<>(1); in testInvalidInput() local 122 mLoader.loadDocInfo(invalidUri, mUserId, consumer); in testInvalidInput() 127 consumer.assertCalled(1000, TimeUnit.MILLISECONDS); in testInvalidInput() 128 assertNull(consumer.getValue()); in testInvalidInput() [all …]
|
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
D | Consumers.java | 28 public static <A extends QuietlyCloseable> void consumeCloseable(Consumer<A> consumer, in consumeCloseable() argument 32 accepted = consumer.consume(value); in consumeCloseable() 39 final Consumer<A> consumer, final A value) { in consumeAsync() argument 41 consumer.consume(value); in consumeAsync() 45 consumer.consume(value); in consumeAsync() 52 final Consumer<A> consumer, final A value) { in consumeCloseableAsync() argument 54 consumeCloseable(consumer, value); in consumeCloseableAsync() 58 consumeCloseable(consumer, value); in consumeCloseableAsync() 65 final Handler handler, final Consumer<A> consumer) { in createAsyncConsumer() argument 68 consumeAsync(handler, consumer, value); in createAsyncConsumer() [all …]
|
D | CachedLater.java | 65 for (Consumer<? super A> consumer : waitingConsumers) { in store() 66 if (DBG) Log.d(TAG, "Calling consumer: " + consumer); in store() 67 consumer.consume(value); in store() 79 public void getLater(Consumer<? super A> consumer) { in getLater() argument 90 mWaitingConsumers.add(consumer); in getLater() 95 consumer.consume(value); in getLater()
|
D | Now.java | 29 public void getLater(Consumer<? super C> consumer) { in getLater() argument 30 consumer.consume(getNow()); in getLater()
|
D | SQLiteAsyncQuery.java | 39 public void run(SQLiteDatabase db, Consumer<A> consumer) { in run() argument 41 consumer.consume(result); in run()
|
D | NowOrLaterWrapper.java | 29 public void getLater(final Consumer<? super B> consumer) { in getLater() argument 32 return consumer.consume(get(value)); in getLater()
|
/packages/apps/TvSettings/Settings/src/com/android/tv/settings/users/ |
D | RestrictedProfilePinDialogFragment.java | 109 public void setPin(String pin, String originalPin, Consumer<Boolean> consumer) { in setPin() argument 113 mUiThreadHandler.post(() -> consumer.accept(true)); in setPin() 118 public void deletePin(String oldPin, Consumer<Boolean> consumer) { in deletePin() argument 122 mUiThreadHandler.post(() -> consumer.accept(true)); in deletePin() 127 public void isPinCorrect(String pin, Consumer<Boolean> consumer) { in isPinCorrect() argument 131 mUiThreadHandler.post(() -> consumer.accept(isPinCorrect)); in isPinCorrect() 136 public void isPinSet(Consumer<Boolean> consumer) { in isPinSet() argument 140 mUiThreadHandler.post(() -> consumer.accept(isPinSet)); in isPinSet()
|
/packages/apps/Gallery2/src/com/android/gallery3d/data/ |
D | MediaSet.java | 187 public void enumerateMediaItems(ItemConsumer consumer) { in enumerateMediaItems() argument 188 enumerateMediaItems(consumer, 0); in enumerateMediaItems() 191 public void enumerateTotalMediaItems(ItemConsumer consumer) { in enumerateTotalMediaItems() argument 192 enumerateTotalMediaItems(consumer, 0); in enumerateTotalMediaItems() 202 protected int enumerateMediaItems(ItemConsumer consumer, int startIndex) { in enumerateMediaItems() argument 210 consumer.consume(startIndex + start + i, item); in enumerateMediaItems() 220 ItemConsumer consumer, int startIndex) { in enumerateTotalMediaItems() argument 222 start += enumerateMediaItems(consumer, startIndex); in enumerateTotalMediaItems() 226 consumer, startIndex + start); in enumerateTotalMediaItems()
|
D | ClusterAlbum.java | 83 ItemConsumer consumer = new ItemConsumer() { in getMediaItemFromPath() local 89 dataManager.mapMediaItems(subset, consumer, 0); in getMediaItemFromPath() 98 protected int enumerateMediaItems(ItemConsumer consumer, int startIndex) { in enumerateMediaItems() argument 99 mDataManager.mapMediaItems(mPaths, consumer, startIndex); in enumerateMediaItems() 128 ItemConsumer consumer = new ItemConsumer() { in delete() local 136 mDataManager.mapMediaItems(mPaths, consumer, 0); in delete()
|
D | LocalSource.java | 192 public void mapMediaItems(ArrayList<PathId> list, ItemConsumer consumer) { in mapMediaItems() argument 208 processMapMediaItems(imageList, consumer, true); in mapMediaItems() 209 processMapMediaItems(videoList, consumer, false); in mapMediaItems() 213 ItemConsumer consumer, boolean isImage) { in processMapMediaItems() argument 239 consumer.consume(pid2.id, items[k - i]); in processMapMediaItems()
|
D | MediaSource.java | 76 public void mapMediaItems(ArrayList<PathId> list, ItemConsumer consumer) { in mapMediaItems() argument 92 consumer.consume(pid.id, (MediaItem) obj); in mapMediaItems()
|
D | FilterTypeSet.java | 127 ItemConsumer consumer = new ItemConsumer() { in delete() local 135 mDataManager.mapMediaItems(mPaths, consumer, 0); in delete()
|
/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/ |
D | IconLoaderTest.java | 50 AssertConsumer<Object> consumer = new AssertConsumer<Object>(); in assertNull() local 51 value.getLater(consumer); in assertNull() 52 consumer.assertNull(); in assertNull() 60 AssertConsumer<Object> consumer = new AssertConsumer<Object>(); in assertNotNull() local 61 value.getLater(consumer); in assertNotNull() 62 consumer.assertNotNull(); in assertNotNull()
|
/packages/apps/Car/libs/car-apps-common/src/com/android/car/apps/common/imaging/ |
D | LocalImageFetcher.java | 127 public void getImage(Context context, ImageKey key, BiConsumer<ImageKey, Drawable> consumer) { in getImage() argument 130 consumer.accept(key, cached); in getImage() 144 consumers.add(consumer); in getImage() 163 public void cancelRequest(ImageKey key, BiConsumer<ImageKey, Drawable> consumer) { in cancelRequest() argument 166 boolean removed = consumers.remove(consumer); in cancelRequest() 202 for (BiConsumer<ImageKey, Drawable> consumer : consumers) { in fulfilRequests() 203 consumer.accept(key, drawable); in fulfilRequests()
|
D | ImageBinder.java | 85 @NonNull Consumer<Drawable> consumer) { in ImageBinder() argument 88 mClient = checkNotNull(consumer, "Cannot bind a null consumer"); in ImageBinder()
|
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/ |
D | QueryTask.java | 51 Handler handler, Consumer<C> consumer) { in QueryTask() argument 56 mConsumer = consumer; in QueryTask() 80 Consumer<C> consumer) { in startQuery() argument 83 consumer); in startQuery()
|
/packages/apps/Launcher3/quickstep/src/com/android/quickstep/util/ |
D | CachedEventDispatcher.java | 51 public void setConsumer(Consumer<MotionEvent> consumer) { in setConsumer() argument 52 if (consumer == null) { in setConsumer() 55 mConsumer = consumer; in setConsumer()
|
/packages/services/Telephony/src/com/android/phone/settings/ |
D | PickSmsSubscriptionActivity.java | 64 public static void addPendingResult(IIntegerConsumer consumer) { in addPendingResult() argument 66 sSmsPickPendingList.add(consumer); in addPendingResult() 68 Log.i(LOG_TAG, "queue pending result, token: " + consumer); in addPendingResult()
|
/packages/services/Telephony/src/com/android/phone/ |
D | ImsRcsController.java | 119 public void getImsRcsRegistrationState(int subId, IIntegerConsumer consumer) { in getImsRcsRegistrationState() argument 125 consumer.accept((regState == null) in getImsRcsRegistrationState() 140 public void getImsRcsRegistrationTransportType(int subId, IIntegerConsumer consumer) { in getImsRcsRegistrationTransportType() argument 151 consumer.accept(regTechConverted); in getImsRcsRegistrationTransportType()
|
/packages/modules/CellBroadcastService/tests/src/com/android/cellbroadcastservice/tests/ |
D | GsmCellBroadcastHandlerTest.java | 197 Consumer<Location> consumer = consumerCaptor.getValue(); in testTriggerMessage() local 198 consumer.accept(Mockito.mock(Location.class)); in testTriggerMessage() 247 Consumer<Location> consumer = captor.getValue(); in testGeofencingAlertOutOfPolygon() local 248 consumer.accept(Mockito.mock(Location.class)); in testGeofencingAlertOutOfPolygon()
|
/packages/apps/Launcher3/src/com/android/launcher3/testing/ |
D | TestLogging.java | 55 static void setEventConsumer(BiConsumer<String, String> consumer) { in setEventConsumer() argument 56 sEventConsumer = consumer; in setEventConsumer()
|
/packages/modules/NetworkStack/common/networkstackclient/src/android/net/networkstack/ |
D | NetworkStackClientBase.java | 138 for (Consumer<INetworkStackConnector> consumer : requests) { in onNetworkStackConnected() 139 consumer.accept(connector); in onNetworkStackConnected()
|
/packages/apps/TvSettings/Settings/src/com/android/tv/settings/dialog/ |
D | PinDialogFragment.java | 139 public abstract void setPin(String pin, String originalPin, Consumer<Boolean> consumer); in setPin() argument 146 public abstract void deletePin(String oldPin, Consumer<Boolean> consumer); in deletePin() argument 153 public abstract void isPinCorrect(String pin, Consumer<Boolean> consumer); in isPinCorrect() argument 159 public abstract void isPinSet(Consumer<Boolean> consumer); in isPinSet() argument
|
/packages/modules/IPsec/src/java/com/android/internal/net/ipsec/ike/ |
D | IkeLocalRequestScheduler.java | 60 public IkeLocalRequestScheduler(IProcedureConsumer consumer, Context context) { in IkeLocalRequestScheduler() argument 61 mConsumer = consumer; in IkeLocalRequestScheduler()
|
/packages/apps/Car/libs/car-arch-common/src/com/android/car/arch/common/ |
D | LiveDataFunctions.java | 521 public static <T, U> Observer<Pair<T, U>> split(@NonNull BiConsumer<T, U> consumer) { 524 consumer.accept(null, null); 526 consumer.accept(pair.first, pair.second);
|