Lines Matching refs:Consumer
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 on
79 public void getLater(Consumer<? super A> consumer) {
88 mWaitingConsumers = new ArrayList<Consumer<? super A>>();
90 mWaitingConsumers.add(consumer);
94 if (DBG) Log.d(TAG, "valid, calling consumer synchronously");
95 consumer.consume(value);
