| /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/chromium/chrome/common/extensions/docs/examples/apps/hello-python/oauth2/clients/ |
| imap.py | 32 def authenticate(self, url, consumer, token):
33 if consumer is not None and not isinstance(consumer, oauth2.Consumer):
34 raise ValueError("Invalid consumer.")
40 lambda x: oauth2.build_xoauth_string(url, consumer, token))
|
| smtp.py | 33 def authenticate(self, url, consumer, token):
34 if consumer is not None and not isinstance(consumer, oauth2.Consumer):
35 raise ValueError("Invalid consumer.")
41 base64.b64encode(oauth2.build_xoauth_string(url, consumer, token)))
|
| /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(0) {}
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)
42 : consumer(c), Format(Format) {}
61 Consumer &consumer; member in class:llvm::DiffLogBuilder
64 DiffLogBuilder(Consumer &c) : consumer(c) {}
|
| /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/ |
| ShortcutRepository.java | 19 import com.android.quicksearchbox.util.Consumer;
33 * @param consumer Consumer that the result will be passed to.
34 * The value passed to the consumer will always be non-null.
35 * The consumer will be called on an unspecified thread, and will always
38 void hasHistory(Consumer<Boolean> consumer);
67 * @param consumer Consumer that the shortcuts cursor will be passed to.
68 * The shortcut cursor passed to the consumer may be null if there are no shortcuts
[all...] |
| CorpusRanker.java | 19 import com.android.quicksearchbox.util.Consumer;
31 * @param consumer Consumer that will be given the list of ranked corpora.
32 * The consumer is called on an unspecified thread.
36 void getCorporaInAll(Consumer<List<Corpus>> consumer);
|
| QueryTask.java | 19 import com.android.quicksearchbox.util.Consumer;
38 private final Consumer<C> mConsumer;
47 * @param handler Handler that {@link Consumer#consume} will
49 * @param consumer Consumer to notify when the suggestions have been returned.
53 Handler handler, Consumer<C> consumer, boolean onlyTask) {
58 mConsumer = consumer;
81 Consumer<C> consumer, boolean onlyOneProvider)
[all...] |
| /external/harfbuzz_ng/util/ |
| main-font-text.hh | 41 consumer (&options) {}
58 consumer.init (&font_opts);
64 consumer.consume_line (buffer, text, text_len, input.text_before, input.text_after);
67 consumer.finish (&font_opts);
69 return consumer.failed ? 1 : 0;
76 consumer_t consumer; member in struct:main_font_text_t
|
| /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> {
|
| MockShortcutRepository.java | 19 import com.android.quicksearchbox.util.Consumer;
46 boolean allowWebSearchShortcuts, Consumer<ShortcutCursor> consumer) {
48 consumer.consume(cursor);
65 public void getCorpusScores(Consumer<Map<String, Integer>> consumer) {
66 consumer.consume(mCorpusScores);
69 public void hasHistory(Consumer<Boolean> consumer) {
70 consumer.consume(false)
[all...] |
| /external/chromium/chrome/browser/geolocation/ |
| access_token_store_browsertest.cc | 44 CancelableRequestConsumerBase* consumer,
49 (*store)->LoadAccessTokens(consumer, callback);
61 CancelableRequestConsumer consumer; local
66 store->LoadAccessTokens(&consumer, NewCallback(
68 EXPECT_TRUE(consumer.HasPendingRequests());
70 consumer.GetClientData(store.get(), first_handle);
72 EXPECT_FALSE(consumer.HasPendingRequests());
75 store->LoadAccessTokens(&consumer, NewCallback(
77 store->LoadAccessTokens(&consumer, NewCallback(
79 EXPECT_TRUE(consumer.HasPendingRequests())
[all...] |
| /external/chromium/chrome/browser/password_manager/ |
| password_store.cc | 68 const PasswordForm& form, PasswordStoreConsumer* consumer) {
69 return Schedule(&PasswordStore::GetLoginsImpl, consumer, form);
73 PasswordStoreConsumer* consumer) {
74 return Schedule(&PasswordStore::GetAutofillableLoginsImpl, consumer);
78 PasswordStoreConsumer* consumer) {
79 return Schedule(&PasswordStore::GetBlacklistLoginsImpl, consumer);
112 BackendFunc func, PasswordStoreConsumer* consumer) {
114 NewCallback(consumer,
116 AddRequest(request, consumer->cancelable_consumer());
123 BackendFunc func, PasswordStoreConsumer* consumer, const ArgA& a)
[all...] |
| /external/chromium/chrome/common/net/gaia/ |
| gaia_auth_fetcher_unittest.cc | 156 MockGaiaConsumer consumer; local
157 EXPECT_CALL(consumer, OnClientLoginFailure(expected_error))
160 GaiaAuthFetcher auth(&consumer, std::string(),
178 MockGaiaConsumer consumer; local
179 EXPECT_CALL(consumer, OnIssueAuthTokenFailure(_, expected_error))
182 GaiaAuthFetcher auth(&consumer, std::string(),
201 MockGaiaConsumer consumer; local
202 EXPECT_CALL(consumer, OnClientLoginFailure(expected_error))
205 GaiaAuthFetcher auth(&consumer, std::string(),
250 MockGaiaConsumer consumer; local
266 MockGaiaConsumer consumer; local
300 MockGaiaConsumer consumer; local
375 MockGaiaConsumer consumer; local
397 MockGaiaConsumer consumer; local
420 MockGaiaConsumer consumer; local
450 MockGaiaConsumer consumer; local
475 MockGaiaConsumer consumer; local
[all...] |
| /external/chromium/chrome/browser/chromeos/login/ |
| authenticator.cc | 20 Authenticator::Authenticator(LoginStatusConsumer* consumer)
21 : consumer_(consumer) {
|
| google_authenticator_unittest.cc | 218 MockConsumer consumer; local
219 EXPECT_CALL(consumer, OnLoginSuccess(username_, password_, _, false))
227 scoped_refptr<GoogleAuthenticator> auth(new GoogleAuthenticator(&consumer));
235 MockConsumer consumer; local
236 EXPECT_CALL(consumer, OnLoginFailure(_))
244 scoped_refptr<GoogleAuthenticator> auth(new GoogleAuthenticator(&consumer));
250 MockConsumer consumer; local
251 EXPECT_CALL(consumer, OnPasswordChangeDetected(result_))
254 EXPECT_CALL(consumer, OnLoginSuccess(username_, password_, result_, false))
273 scoped_refptr<GoogleAuthenticator> auth(new GoogleAuthenticator(&consumer));
280 MockConsumer consumer; local
305 MockConsumer consumer; local
338 MockConsumer consumer; local
356 MockConsumer consumer; local
374 MockConsumer consumer; local
389 MockConsumer consumer; local
404 MockConsumer consumer; local
424 MockConsumer consumer; local
439 MockConsumer consumer; local
457 MockConsumer consumer; local
478 MockConsumer consumer; local
497 MockConsumer consumer; local
538 MockConsumer consumer; local
578 MockConsumer consumer; local
616 MockConsumer consumer; local
665 MockConsumer consumer; local
[all...] |
| /external/chromium/chrome/browser/webdata/ |
| web_data_service_unittest.cc | 178 AutofillWebDataServiceConsumer<std::vector<string16> > consumer; local
182 name1_, string16(), limit, &consumer);
184 // The message loop will exit when the consumer is called.
187 EXPECT_EQ(handle, consumer.handle());
188 ASSERT_EQ(1U, consumer.result().size());
189 EXPECT_EQ(value1_, consumer.result()[0]);
272 AutofillWebDataServiceConsumer<std::vector<AutofillProfile*> > consumer; local
273 WebDataService::Handle handle = wds_->GetAutofillProfiles(&consumer);
275 EXPECT_EQ(handle, consumer.handle());
276 ASSERT_EQ(1U, consumer.result().size())
292 AutofillWebDataServiceConsumer<std::vector<AutofillProfile*> > consumer; local
337 AutofillWebDataServiceConsumer<std::vector<AutofillProfile*> > consumer; local
393 AutofillWebDataServiceConsumer<std::vector<CreditCard*> > consumer; local
412 AutofillWebDataServiceConsumer<std::vector<CreditCard*> > consumer; local
457 AutofillWebDataServiceConsumer<std::vector<CreditCard*> > consumer; local
[all...] |
| /external/chromium/chrome/browser/chromeos/cros/ |
| syslogs_library.h | 33 CancelableRequestConsumerBase* consumer,
|
