| /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...] |
| 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
|
| NoOpConsumer.java | 19 import com.android.quicksearchbox.util.Consumer;
22 * A Consumer that does nothing with the objects it receives.
24 public class NoOpConsumer<A> implements Consumer<A> {
|
| Now.java | 29 public void getLater(Consumer<? super C> consumer) {
30 consumer.consume(getNow());
|
| 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);
|
| 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);
|
| /external/llvm/tools/llvm-diff/ |
| 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...] |
| 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...] |
| /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/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...] |
| /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> {
|
| ConsumerTrap.java | 19 import com.android.quicksearchbox.util.Consumer;
22 * A consumer that saves the value that it is given.
26 public class ConsumerTrap<A> implements Consumer<A> {
|
| /external/clang/lib/Frontend/ |
| MultiplexConsumer.cpp | 1 //===- MultiplexConsumer.cpp - AST Consumer for PCH Generation --*- C++ -*-===//
238 for (auto &Consumer : Consumers) {
239 if (auto *mutationListener = Consumer->GetASTMutationListener())
241 if (auto *serializationListener = Consumer->GetASTDeserializationListener())
258 for (auto &Consumer : Consumers)
259 Consumer->Initialize(Context);
264 for (auto &Consumer : Consumers)
265 Continue = Continue && Consumer->HandleTopLevelDecl(D);
270 for (auto &Consumer : Consumers)
271 Consumer->HandleInlineMethodDefinition(D)
[all...] |
| /libcore/luni/src/test/java/libcore/java/util/function/ |
| ConsumerTest.java | 21 import java.util.function.Consumer;
26 Consumer<StringBuilder> sweet = s -> s.append("sweet");
27 Consumer<StringBuilder> dude = s -> s.append("dude");
39 Consumer<StringBuilder> one = s -> s.append("one");
|
| /external/v8/src/profiler/ |
| circular-queue.h | 17 // single producer and a single consumer. If the queue is full,
32 // memory returned by StartEnqueue and it can be passed to the consumer.
35 // Executed on the consumer (analyzer) thread.
37 // if this queue is empty. After the record had been read by a consumer,
47 // completely processed by the consumer.
|
| /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...] |
| /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...] |
| /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
|
| Makefile.sources | 8 shape-consumer.hh \
24 shape-consumer.hh \
|
| /libcore/ojluni/src/main/java/java/util/function/ |
| Consumer.java | 31 * result. Unlike most other functional interfaces, {@code Consumer} is expected
42 public interface Consumer<T> {
52 * Returns a composed {@code Consumer} that performs, in sequence, this
59 * @return a composed {@code Consumer} that performs in sequence this
63 default Consumer<T> andThen(Consumer<? super T> after) {
|
| /frameworks/av/services/camera/libcameraservice/device3/ |
| Camera3OutputStream.h | 81 Camera3OutputStream(int id, sp<Surface> consumer,
92 Camera3OutputStream(int id, sp<Surface> consumer,
98 * Set up a stream with deferred consumer for formats that have 2 dimensions, such as
99 * RAW and YUV. The consumer must be set before using this stream for output. A valid
136 * Return if the consumer configuration of this stream is deferred.
141 * Set the consumer surface to the output stream.
143 virtual status_t setConsumer(sp<Surface> consumer);
150 * Implementation of IProducerListener, used to notify this stream that the consumer
198 // Name of Surface consumer
201 // Whether consumer assumes MONOTONIC timestam
[all...] |
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| StreamTestScenario.java | 30 import java.util.function.Consumer;
47 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
60 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
70 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
80 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
89 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
97 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
105 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
113 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
121 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m)
[all...] |
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| StreamTestScenario.java | 30 import java.util.function.Consumer;
50 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
63 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
73 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
83 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
92 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
100 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
108 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
116 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
124 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m)
[all...] |
