Searched refs:future (Results 1 – 19 of 19) sorted by relevance
51 final SettableFuture<CompressionResult> future = SettableFuture.create(); in compress() local54 future.set(immediateCompress(source)); in compress()56 future.setException(e); in compress()60 return future; in compress()
134 Future<?> future = in testAllowInterruptAsync() local143 future.get(500L, TimeUnit.MILLISECONDS); in testAllowInterruptAsync()161 Future<?> future = in testAllowInterruptsAsync_alreadyAllowed() local164 assertTrue(future.isDone()); in testAllowInterruptsAsync_alreadyAllowed()
119 future = self._executor.submit(name, *args, **kwargs)120 return future126 future = self._executor.submit(128 return future326 def future(self): member in RpcClient
115 val future = CompletableFuture<List<U>>() in par_map() constant118 future.complete(source.map { map(state, it) }) in par_map()120 resultPipe.put(future) in par_map()
66 for (Future<V> future : futures) { in invokeAll()68 results.add(future.get(timeout, unit)); in invokeAll()
104 Future<T> future = in invocation() local114 return Futures.getUnchecked(future); in invocation()
101 for (Future<HashMap<String, Metric>> future : futures) { in testAddToMetricsMultiThreaded()102 metricsData.putAll(future.get()); in testAddToMetricsMultiThreaded()
373 for future in concurrent.futures.as_completed(future_to_params):374 params = future_to_params[future]376 return_vals.append(future.result())1158 for future in futures:1160 results.append(future.result())1224 for future in futures:1226 results.append(future.result())
18 from future import standard_library
108 for (Future<?> future : jobs) { in testMultithreadedVersionMatchesSinglethreaded()109 future.get(); in testMultithreadedVersionMatchesSinglethreaded()
17 from future.moves.urllib.request import urlopen
194 self.assertEqual(client.future, client._async_client)
19 from future import standard_library
17 from future import standard_library
29 - future
95 In the near future the build system will not allow source files to be modified
426 // release -- sorry, we'll try to include it in a future version!642 // be recorded in the future.
539 futrue||future
META-INF/ META-INF/MANIFEST.MF jline/ jline/CompletionHandler.class CompletionHandler ...