*/ class ListQueuesResult extends Result implements \IteratorAggregate { /** * A list of queue URLs, up to 1,000 entries, or the value of `MaxResults` that you sent in the request. * * @var string[] */ private $queueUrls; /** * Pagination token to include in the next request. Token value is `null` if there are no additional results to request, * or if you did not set `MaxResults` in the request. * * @var string|null */ private $nextToken; /** * Iterates over QueueUrls. * * @return \Traversable */ public function getIterator(): \Traversable { yield from $this->getQueueUrls(); } public function getNextToken(): ?string { $this->initialize(); return $this->nextToken; } /** * @param bool $currentPageOnly When true, iterates over items of the current page. Otherwise also fetch items in the next pages. * * @return iterable */ public function getQueueUrls(bool $currentPageOnly = false): iterable { if ($currentPageOnly) { $this->initialize(); yield from $this->queueUrls; return; } $client = $this->awsClient; if (!$client instanceof SqsClient) { throw new InvalidArgument('missing client injected in paginated result'); } if (!$this->input instanceof ListQueuesRequest) { throw new InvalidArgument('missing last request injected in paginated result'); } $input = clone $this->input; $page = $this; while (true) { $page->initialize(); if (null !== $page->nextToken) { $input->setNextToken($page->nextToken); $this->registerPrefetch($nextPage = $client->listQueues($input)); } else { $nextPage = null; } yield from $page->queueUrls; if (null === $nextPage) { break; } $this->unregisterPrefetch($nextPage); $page = $nextPage; } } protected function populateResult(Response $response): void { $data = $response->toArray(); $this->queueUrls = empty($data['QueueUrls']) ? [] : $this->populateResultQueueUrlList($data['QueueUrls']); $this->nextToken = isset($data['NextToken']) ? (string) $data['NextToken'] : null; } /** * @return string[] */ private function populateResultQueueUrlList(array $json): array { $items = []; foreach ($json as $item) { $a = isset($item) ? (string) $item : null; if (null !== $a) { $items[] = $a; } } return $items; } }