| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| local_file_system.py | 10 from future import Future
80 return Future(value=result)
83 return Future(value=())
|
| caching_file_system.py | 9 from future import Future
100 return Future(exc_info=sys.exc_info())
112 return Future(value=results)
114 return Future(delegate=_AsyncUncachedFuture(
|
| features_bundle.py | 9 from future import Gettable, Future
59 return Future(value={})
92 return Future(value=api_features)
110 return Future(delegate=Gettable(resolve))
|
| file_system.py | 5 from future import Gettable, Future
15 return Future(delegate=Gettable(boom))
67 to only happen once the Future has been resolved (Get() called).
74 '''Reads a single file from the FileSystem. Returns a Future with the same
78 return Future(delegate=Gettable(lambda: read_single.Get()[path]))
82 future to its completion.
|
| appengine_url_fetcher.py | 9 from future import Future
46 """Fetches a file asynchronously, and returns a Future with the result.
52 return Future(delegate=_AsyncFetchDelegate(rpc))
|
| chained_compiled_file_system.py | 7 from future import Gettable, Future
85 return Future(delegate=Gettable(resolve))
|
| redirector.py | 9 from future import Gettable, Future
69 return Future(delegate=Gettable(lambda: [f.Get() for f in futures]))
|
| test_object_store.py | 5 from future import Future
12 is a special case; it is only incremented once the future has had Get called.
33 return Future(delegate=FutureImpl())
|
| patched_file_system.py | 8 from future import Gettable, Future
51 return Future(delegate=Gettable(raise_file_not_found))
57 return Future(delegate=_AsyncFetchFuture(
|
| test_file_system.py | 6 from future import Future
54 return Future(delegate=Delegate())
57 return Future(value=())
|
| github_file_system.py | 14 from future import Future
105 self._zip_file = Future(value=None)
109 self._zip_file = Future(value=ZipFile(StringIO(blob)))
114 self._zip_file = Future(value=None)
116 self._zip_file = Future(
165 return Future(value=result)
|
| api_models.py | 11 from future import Gettable, Future
68 for future in futures:
70 return future.Get()
74 return Future(delegate=Gettable(resolve))
|
| fake_url_fetcher.py | 7 from future import Gettable, Future
52 return Future(delegate=Gettable(resolve))
100 return Future(value=self.Fetch(url))
118 future = self._fetcher.FetchAsync(url, **kwargs)
121 return future.Get()
122 return Future(delegate=Gettable(resolve))
|
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| TestSSLSocketPair.java | 23 import java.util.concurrent.Future;
80 Future s = executor.submit(new Callable<Void>() {
89 Future c = executor.submit(new Callable<Void>() {
|
| /packages/apps/Gallery2/src/com/android/gallery3d/ui/ |
| DetailsAddressResolver.java | 26 import com.android.gallery3d.util.Future;
36 private Future<Address> mAddressLookupJob;
68 public void onFutureDone(final Future<Address> future) {
70 if (!future.isCancelled()) {
74 updateLocation(future.get());
|
| /external/smack/src/org/jivesoftware/smackx/filetransfer/ |
| FaultTolerantNegotiator.java | 85 List<Future<InputStream>> futures = new ArrayList<Future<InputStream>>();
94 Future<InputStream> future; local
97 future = service.poll(10, TimeUnit.SECONDS);
103 if (future == null) {
108 stream = future.get();
119 for (Future<InputStream> future : futures) {
120 future.cancel(true)
[all...] |
| /frameworks/volley/src/com/android/volley/toolbox/ |
| RequestFuture.java | 24 import java.util.concurrent.Future;
29 * A Future that represents a Volley request.
33 * RequestFuture<JSONObject> future = RequestFuture.newFuture();
34 * MyRequest request = new MyRequest(URL, future, future);
37 * future.setRequest(requestQueue.add(request));
43 * JSONObject response = future.get();
52 * @param <T> The type of parsed response this future expects.
54 public class RequestFuture<T> implements Future<T>, Response.Listener<T>,
|
| /packages/apps/Gallery2/src/com/android/gallery3d/data/ |
| ComboAlbum.java | 19 import com.android.gallery3d.util.Future;
100 public Future<Integer> requestSync(SyncListener listener) {
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| MoreExecutorsTest.java | 35 import java.util.concurrent.Future;
72 Future<?> future = executor.submit(incrementTask);
73 assertTrue(future.isDone());
83 ListenableFuture<?> future = executor.submit(incrementTask); local
84 assertTrue(future.isDone());
85 assertListenerRunImmediately(future);
113 List<Future<Integer>> futures =
117 Future<Integer> future = futures.get(i) local
[all...] |
| /cts/tests/tests/holo/src/android/holo/cts/ |
| ThemeTestActivity.java | 28 import java.util.concurrent.Future;
157 public Future<Result> getResultFuture() {
178 class ResultFuture<T> implements Future<T> {
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| Uninterruptibles.java | 27 import java.util.concurrent.Future;
118 * Invokes {@code future.}{@link Future#get() get()} uninterruptibly.
123 * with other exceptions, see {@link Futures#get(Future, Class) Futures.get}
126 public static <V> V getUninterruptibly(Future<V> future)
132 return future.get();
146 * {@code future.}{@link Future#get(long, TimeUnit) get(timeout, unit)}
150 * with other exceptions, see {@link Futures#get(Future, Class) Futures.get
[all...] |
| /external/guava/guava-tests/test/com/google/common/collect/ |
| ConcurrentHashMultisetBasherTest.java | 33 import java.util.concurrent.Future;
72 List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks);
78 for (Future<int[]> future : futures) {
79 int[] taskDeltas = future.get();
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/ |
| BroadcastInterceptingContext.java | 33 import java.util.concurrent.Future;
84 public Future<Intent> nextBroadcastIntent(String action) {
88 public Future<Intent> nextBroadcastIntent(IntentFilter filter) {
|
| /packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/util/ |
| ThreadPool.java | 97 public <T> Future<T> submit(Job<T> job, FutureListener<T> listener) {
103 public <T> Future<T> submit(Job<T> job) {
107 private class Worker<T> implements Runnable, Future<T>, JobContext {
148 // Below are the methods for Future.
|
| /packages/apps/Gallery2/src/com/android/gallery3d/app/ |
| SlideshowDataAdapter.java | 26 import com.android.gallery3d.util.Future;
60 private Future<Void> mReloadTask;
174 public Future<Slide> nextSlide(FutureListener<Slide> listener) {
|
