| /packages/apps/DocumentsUI/tests/unit/com/android/documentsui/inspector/ |
| D | DocumentLoaderTest.java | 101 LatchedConsumer<DocumentInfo> consumer = new LatchedConsumer<>(1); in testLoadsDocument() local
102 mLoader.loadDocInfo(validUri, consumer); in testLoadsDocument()
107 consumer.assertCalled(1000, TimeUnit.MILLISECONDS); in testLoadsDocument()
109 assertNotNull(consumer.getValue()); in testLoadsDocument()
110 assertEquals(consumer.getValue().displayName, TEST_DOC_NAME); in testLoadsDocument()
111 assertEquals(consumer.getValue().size, 0); in testLoadsDocument()
122 LatchedConsumer<DocumentInfo> consumer = new LatchedConsumer<>(1); in testInvalidInput() local
123 mLoader.loadDocInfo(invalidUri, consumer); in testInvalidInput()
128 consumer.assertCalled(1000, TimeUnit.MILLISECONDS); in testInvalidInput()
129 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/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()
|
| D | SecureAlbum.java | 99 ItemConsumer consumer = new ItemConsumer() { in getMediaItem() local
105 mDataManager.mapMediaItems(subset, consumer, 0); in getMediaItem()
|
| D | DataManager.java | 217 public void mapMediaItems(ArrayList<Path> list, ItemConsumer consumer, in mapMediaItems() argument
239 source.mapMediaItems(entry.getValue(), consumer); in mapMediaItems() local
|
| /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 | 129 public void getImage(Context context, ImageKey key, BiConsumer<ImageKey, Drawable> consumer) { in getImage() argument
132 consumer.accept(key, cached); in getImage()
146 consumers.add(consumer); in getImage()
165 public void cancelRequest(ImageKey key, BiConsumer<ImageKey, Drawable> consumer) { in cancelRequest() argument
168 boolean removed = consumers.remove(consumer); in cancelRequest()
204 for (BiConsumer<ImageKey, Drawable> consumer : consumers) { in fulfilRequests()
205 consumer.accept(key, drawable); in fulfilRequests()
|
| D | ImageBinder.java | 84 @NonNull Consumer<Drawable> consumer) { in ImageBinder() argument
87 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 | 120 public void getImsRcsRegistrationState(int subId, IIntegerConsumer consumer) { in getImsRcsRegistrationState() argument
126 consumer.accept((regState == null) in getImsRcsRegistrationState()
141 public void getImsRcsRegistrationTransportType(int subId, IIntegerConsumer consumer) { in getImsRcsRegistrationTransportType() argument
152 consumer.accept(regTechConverted); in getImsRcsRegistrationTransportType()
|
| /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/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 | 522 public static <T, U> Observer<Pair<T, U>> split(@NonNull BiConsumer<T, U> consumer) {
525 consumer.accept(null, null);
527 consumer.accept(pair.first, pair.second);
|
| /packages/providers/MediaProvider/src/com/android/providers/media/ |
| D | MediaProvider.java | 608 public static void acceptWithExpansion(Consumer<Uri> consumer, Uri uri) { in acceptWithExpansion() argument
610 acceptWithExpansionInternal(consumer, uri, match); in acceptWithExpansion()
628 acceptWithExpansionInternal(consumer, builder.build(), match); in acceptWithExpansion()
635 private static void acceptWithExpansionInternal(Consumer<Uri> consumer, Uri uri, int match) { in acceptWithExpansionInternal() argument
637 consumer.accept(uri); in acceptWithExpansionInternal()
647 consumer.accept(Files.getContentUri(volumeName, id)); in acceptWithExpansionInternal()
648 consumer.accept(Downloads.getContentUri(volumeName, id)); in acceptWithExpansionInternal()
655 consumer.accept(Files.getContentUri(volumeName)); in acceptWithExpansionInternal()
656 consumer.accept(Downloads.getContentUri(volumeName)); in acceptWithExpansionInternal()
663 consumer.accept(Audio.Media.getContentUri(volumeName, id)); in acceptWithExpansionInternal()
[all …]
|
| /packages/apps/Gallery2/src/com/android/gallery3d/filtershow/imageshow/ |
| D | PrimaryImage.java | 334 Buffer consumer = mPreviewBuffer.getConsumer(); in getFilteredImage() local
335 if (consumer != null) { in getFilteredImage()
336 return consumer.getBitmap(); in getFilteredImage()
|