Home
last modified time | relevance | path

Searched refs:wait_futures (Results 1 – 5 of 5) sorted by relevance

/dports/editors/helix/helix-0.5.0/helix-term/src/
H A Djob.rs21 pub wait_futures: FuturesUnordered<JobFuture>, field
83 event = self.wait_futures.next() => { event } in next_job()
89 self.wait_futures.push(j.future); in add()
97 let wait_futures = std::mem::take(&mut self.wait_futures); in finish() localVariable
98 helix_lsp::block_on(wait_futures.for_each(|_| future::ready(()))); in finish()
H A Dapplication.rs204 Some(callback) = self.jobs.wait_futures.next() => { in event_loop()
/dports/devel/arcanist/arcanist-b2e715f/src/hardpoint/
H A DArcanistHardpointEngine.php192 $wait_futures = $this->waitFutures;
193 if ($wait_futures) {
197 foreach ($wait_futures as $wait_future) {
203 foreach ($wait_futures as $wait_future) {
/dports/devel/arcanist-lib/arcanist-b2e715f/src/hardpoint/
H A DArcanistHardpointEngine.php192 $wait_futures = $this->waitFutures;
193 if ($wait_futures) {
197 foreach ($wait_futures as $wait_future) {
203 foreach ($wait_futures as $wait_future) {
/dports/databases/py-cassandra-driver/cassandra-driver-3.18.0/cassandra/
H A Dcluster.py23 from concurrent.futures import ThreadPoolExecutor, FIRST_COMPLETED, wait as wait_futures unknown
1173 _, not_done = wait_futures(futures, pool_wait_timeout)
1385 wait_futures(session._initial_connect_futures)
2190 futures = wait_futures(self._initial_connect_futures, return_when=FIRST_COMPLETED)
2192 futures = wait_futures(futures.not_done, return_when=FIRST_COMPLETED)
2565 wait_futures(self._initial_connect_futures)