| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| Consumers.java | 22 * Consumer utilities.
28 public static <A extends QuietlyCloseable> void consumeCloseable(Consumer<A> consumer,
32 accepted = consumer.consume(value);
39 final Consumer<A> consumer, final A value) {
41 consumer.consume(value);
45 consumer.consume(value);
52 final Consumer<A> consumer, final A value)
[all...] |
| NowOrLater.java | 21 * be sent to a {@link Consumer} later.
38 * which case the callback may be made in context. The thread on which the consumer is called
41 void getLater(Consumer<? super C> consumer);
|
| Now.java | 29 public void getLater(Consumer<? super C> consumer) {
30 consumer.consume(getNow());
|
| SQLiteAsyncQuery.java | 37 * Runs the query against the database and passes the result to the consumer.
39 public void run(SQLiteDatabase db, Consumer<A> consumer) {
41 consumer.consume(result);
|
| CachedLater.java | 42 private List<Consumer<? super A>> mWaitingConsumers;
56 List<Consumer<? super A>> waitingConsumers;
65 for (Consumer<? super A> consumer : waitingConsumers) {
66 if (DBG) Log.d(TAG, "Calling consumer: " + consumer);
67 consumer.consume(value);
75 * @param consumer A consumer that will be given the cached value.
76 * The consumer may be called synchronously, or asynchronously o
[all...] |
| NowOrLaterWrapper.java | 29 public void getLater(final Consumer<? super B> consumer) {
30 mWrapped.getLater(new Consumer<A>(){
32 return consumer.consume(get(value));
46 * {@link #getLater(Consumer)} or {@link #getNow()}. The thread that it's called on will depend
|
| /external/llvm/tools/llvm-diff/ |
| DifferenceEngine.h | 39 Engine.consumer.enterContext(L, R);
43 Engine.consumer.exitContext();
61 DifferenceEngine(Consumer &consumer)
62 : consumer(consumer), globalValueOracle(nullptr) {}
67 consumer.log(text);
70 return LogBuilder(consumer, text);
72 Consumer& getConsumer() const { return consumer; }
86 Consumer &consumer; member in class:llvm::DifferenceEngine
[all...] |
| DiffLog.h | 23 class Consumer;
30 Consumer *consumer; member in class:llvm::LogBuilder
41 LogBuilder(Consumer &c, StringRef Format) : consumer(&c), Format(Format) {}
43 : consumer(L.consumer), Format(L.Format),
45 L.consumer = nullptr;
65 Consumer &consumer; member in class:llvm::DiffLogBuilder
[all...] |
| DiffLog.cpp | 23 if (consumer)
24 consumer->logf(*this);
32 DiffLogBuilder::~DiffLogBuilder() { consumer.logd(*this); }
|
| /external/smali/smalidea/src/main/java/org/jf/smalidea/ |
| SmaliFileTypeFactory.java | 40 public void createFileTypes(@NotNull FileTypeConsumer consumer) {
41 consumer.consume(SmaliFileType.INSTANCE, SmaliFileType.DEFAULT_EXTENSION);
|
| /external/oauth/core/src/main/java/net/oauth/ |
| ConsumerProperties.java | 28 * A pool of OAuthConsumers that are constructed from Properties. Each consumer
30 * from Properties whose names are prefixed with the consumer's name. For
31 * example, a consumer's credentials come from properties named
72 /** Get the consumer with the given name. */
74 OAuthConsumer consumer; local
76 consumer = pool.get(name);
78 if (consumer == null) {
79 consumer = newConsumer(name);
84 pool.put(name, consumer);
90 consumer = first
105 OAuthConsumer consumer = new OAuthConsumer(consumerProperties local
[all...] |
| OAuthAccessor.java | 38 public final OAuthConsumer consumer; field in class:OAuthAccessor
43 public OAuthAccessor(OAuthConsumer consumer) {
44 this.consumer = consumer;
68 * consumer.getProperty("httpMethod") or (if that's null)
77 method = (String) this.consumer.getProperty("httpMethod");
85 Object accepted = consumer.getProperty(OAuthConsumer.ACCEPT_ENCODING);
|
| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/ |
| IconLoaderTest.java | 19 import com.android.quicksearchbox.util.Consumer;
50 AssertConsumer<Object> consumer = new AssertConsumer<Object>(); local
51 value.getLater(consumer);
52 consumer.assertNull();
60 AssertConsumer<Object> consumer = new AssertConsumer<Object>(); local
61 value.getLater(consumer);
62 consumer.assertNotNull();
66 protected static class AssertConsumer<C> implements Consumer<C> {
|
| /external/harfbuzz_ng/util/ |
| main-font-text.hh | 73 consumer (&options) {}
90 consumer.init (&font_opts);
98 consumer.consume_line (buffer, text, text_len, input.text_before, input.text_after);
101 consumer.finish (&font_opts);
103 return consumer.failed ? 1 : 0;
110 consumer_t consumer; member in struct:main_font_text_t
|
| /frameworks/av/services/camera/libcameraservice/gui/ |
| RingBufferConsumer.h | 61 // Create a new ring buffer consumer. The consumerUsage parameter determines
62 // the consumer usage flags passed to the graphics allocator. The
65 RingBufferConsumer(const sp<IGraphicBufferConsumer>& consumer, uint32_t consumerUsage,
83 // setConsumerUsage allows the BufferQueue consumer usage to be
122 PinnedBufferItem(wp<RingBufferConsumer> consumer,
124 mConsumer(consumer),
129 sp<RingBufferConsumer> consumer = mConsumer.promote(); local
130 if (consumer != NULL) {
131 consumer->unpinBuffer(mBufferItem);
|
| /frameworks/av/services/camera/libcameraservice/device3/ |
| Camera3OutputStreamInterface.h | 44 * Return if the consumer configuration of this stream is deferred.
49 * Set the consumer surface to the output stream.
51 virtual status_t setConsumer(sp<Surface> consumer) = 0;
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/ |
| QueryTask.java | 19 import com.android.quicksearchbox.util.Consumer;
38 private final Consumer<C> mConsumer;
46 * @param handler Handler that {@link Consumer#consume} will
48 * @param consumer Consumer to notify when the suggestions have been returned.
51 Handler handler, Consumer<C> consumer) {
56 mConsumer = consumer;
80 Consumer<C> consumer) {
[all...] |
| /dalvik/dx/src/com/android/dx/cf/direct/ |
| ClassPathOpener.java | 42 private final Consumer consumer; field in class:ClassPathOpener
54 public interface Consumer {
71 * Informs consumer that an exception occurred while processing
79 * Informs consumer that processing of an archive file has begun.
112 * @param consumer {@code non-null;} callback interface
114 public ClassPathOpener(String pathname, boolean sort, Consumer consumer) {
115 this(pathname, sort, acceptAll, consumer);
125 * @param consumer {@code non-null;} callback interfac
[all...] |
| /frameworks/native/libs/gui/tests/ |
| Surface_test.cpp | 95 sp<IGraphicBufferConsumer> consumer; local
96 BufferQueue::createBufferQueue(&producer, &consumer);
97 sp<CpuConsumer> cpuConsumer = new CpuConsumer(consumer, 1);
147 sp<IGraphicBufferConsumer> consumer; local
148 BufferQueue::createBufferQueue(&producer, &consumer);
149 sp<BufferItemConsumer> c = new BufferItemConsumer(consumer,
165 sp<IGraphicBufferConsumer> consumer; local
166 BufferQueue::createBufferQueue(&producer, &consumer);
167 sp<CpuConsumer> cpuConsumer = new CpuConsumer(consumer, 1);
186 sp<IGraphicBufferConsumer> consumer; local
221 sp<IGraphicBufferConsumer> consumer; local
237 sp<IGraphicBufferConsumer> consumer; local
[all...] |
| /libcore/ojluni/src/main/java/java/util/stream/ |
| ForEachOps.java | 32 import java.util.function.Consumer;
41 * traversal (elements are provided to the {@code Consumer} as soon as they are
43 * {@code Consumer} in encounter order.)
45 * <p>Elements are provided to the {@code Consumer} on whatever thread and
51 * {@code Consumer} will be relayed to the caller and traversal will be
64 * @param action the {@code Consumer} that receives all elements of a
70 public static <T> TerminalOp<T, Void> makeRef(Consumer<? super T> action,
175 final Consumer<? super T> consumer; field in class:ForEachOps.ForEachOp.OfRef
177 OfRef(Consumer<? super T> consumer, boolean ordered)
191 final IntConsumer consumer; field in class:ForEachOps.ForEachOp.OfInt
212 final LongConsumer consumer; field in class:ForEachOps.ForEachOp.OfLong
233 final DoubleConsumer consumer; field in class:ForEachOps.ForEachOp.OfDouble
[all...] |
| SpinedBuffer.java | 35 import java.util.function.Consumer;
59 implements Consumer<E>, Iterable<E> {
243 public void forEach(Consumer<? super E> consumer) {
247 consumer.accept(t);
251 consumer.accept(curChunk[i]);
328 public boolean tryAdvance(Consumer<? super E> consumer) {
329 Objects.requireNonNull(consumer);
333 consumer.accept(splChunk[splElementIndex++])
[all...] |
| /external/llvm/utils/lit/lit/ |
| run.py | 69 def __init__(self, run_instance, provider, consumer):
72 self.consumer = consumer
80 self.consumer.task_finished()
91 self.consumer.update(test_index, test)
212 consumer = None
218 consumer = MultiprocessResultsConsumer(self, display, jobs)
224 consumer = None
225 if not consumer:
229 consumer = ThreadResultsConsumer(display
[all...] |
| /packages/apps/Gallery2/src/com/android/gallery3d/data/ |
| ClusterAlbum.java | 83 ItemConsumer consumer = new ItemConsumer() { local
89 dataManager.mapMediaItems(subset, consumer, 0);
98 protected int enumerateMediaItems(ItemConsumer consumer, int startIndex) {
99 mDataManager.mapMediaItems(mPaths, consumer, startIndex);
128 ItemConsumer consumer = new ItemConsumer() { local
136 mDataManager.mapMediaItems(mPaths, consumer, 0);
|
| /libcore/ojluni/src/main/java/java/util/ |
| Random.java | [all...] |
| SplittableRandom.java | [all...] |
