Changeset View
Changeset View
Standalone View
Standalone View
src/hardpoint/ArcanistHardpointEngine.php
| Show First 20 Lines • Show All 186 Lines • ▼ Show 20 Lines | final class ArcanistHardpointEngine | ||||
| private function updateFutures() { | private function updateFutures() { | ||||
| $iterator = $this->futureIterator; | $iterator = $this->futureIterator; | ||||
| $is_rewind = false; | $is_rewind = false; | ||||
| $wait_futures = $this->waitFutures; | $wait_futures = $this->waitFutures; | ||||
| if ($wait_futures) { | if ($wait_futures) { | ||||
| if (!$this->futureIterator) { | if (!$this->futureIterator) { | ||||
| $iterator = new FutureIterator(array()); | $iterator = id(new FutureIterator(array())) | ||||
| ->limit(32); | |||||
| foreach ($wait_futures as $wait_future) { | foreach ($wait_futures as $wait_future) { | ||||
| $iterator->addFuture($wait_future); | $iterator->addFuture($wait_future); | ||||
| } | } | ||||
| $is_rewind = true; | $is_rewind = true; | ||||
| $this->futureIterator = $iterator; | $this->futureIterator = $iterator; | ||||
| } else { | } else { | ||||
| foreach ($wait_futures as $wait_future) { | foreach ($wait_futures as $wait_future) { | ||||
| $iterator->addFuture($wait_future); | $iterator->addFuture($wait_future); | ||||
| Show All 34 Lines | |||||