golden hour
/home/doctorbruno/public_html/doc-noc.com/wp-content/plugins/updraftplus/vendor/aws/aws-sdk-php/src
⬆️ Go Up
Upload
File/Folder
Size
Actions
AbstractConfigurationProvider.php
4.46 KB
Del
OK
Api
-
Del
OK
Arn
-
Del
OK
AwsClient.php
17.59 KB
Del
OK
AwsClientInterface.php
5.4 KB
Del
OK
AwsClientTrait.php
2.67 KB
Del
OK
CacheInterface.php
755 B
Del
OK
ClientResolver.php
43.37 KB
Del
OK
ClientSideMonitoring
-
Del
OK
Command.php
1.39 KB
Del
OK
CommandInterface.php
946 B
Del
OK
CommandPool.php
5.2 KB
Del
OK
ConfigurationProviderInterface.php
246 B
Del
OK
Credentials
-
Del
OK
DefaultsMode
-
Del
OK
DoctrineCacheAdapter.php
989 B
Del
OK
Endpoint
-
Del
OK
EndpointDiscovery
-
Del
OK
EndpointParameterMiddleware.php
2.73 KB
Del
OK
Exception
-
Del
OK
Handler
-
Del
OK
HandlerList.php
13.24 KB
Del
OK
HasDataTrait.php
1.46 KB
Del
OK
HasMonitoringEventsTrait.php
869 B
Del
OK
HashInterface.php
531 B
Del
OK
HashingStream.php
1.5 KB
Del
OK
History.php
3.9 KB
Del
OK
Iam
-
Del
OK
IdempotencyTokenMiddleware.php
3.69 KB
Del
OK
InputValidationMiddleware.php
2.44 KB
Del
OK
JsonCompiler.php
478 B
Del
OK
Keyspaces
-
Del
OK
LruArrayCache.php
2.22 KB
Del
OK
Middleware.php
12.77 KB
Del
OK
MockHandler.php
4.05 KB
Del
OK
MonitoringEventsInterface.php
742 B
Del
OK
MultiRegionClient.php
7.75 KB
Del
OK
Multipart
-
Del
OK
PhpHash.php
1.81 KB
Del
OK
PresignUrlMiddleware.php
4.18 KB
Del
OK
Psr16CacheAdapter.php
572 B
Del
OK
PsrCacheAdapter.php
742 B
Del
OK
ResponseContainerInterface.php
246 B
Del
OK
Result.php
1.14 KB
Del
OK
ResultInterface.php
1.34 KB
Del
OK
ResultPaginator.php
5.24 KB
Del
OK
Retry
-
Del
OK
RetryMiddleware.php
8.47 KB
Del
OK
RetryMiddlewareV2.php
11.67 KB
Del
OK
S3
-
Del
OK
Sdk.php
52.08 KB
Del
OK
Signature
-
Del
OK
StreamRequestPayloadMiddleware.php
2.57 KB
Del
OK
TraceMiddleware.php
12.25 KB
Del
OK
Waiter.php
8.33 KB
Del
OK
WrappedHttpHandler.php
6.97 KB
Del
OK
data
-
Del
OK
functions.php
13.58 KB
Del
OK
Edit: ResultPaginator.php
<?php namespace Aws; use GuzzleHttp\Promise; /** * Iterator that yields each page of results of a pageable operation. */ class ResultPaginator implements \Iterator { /** @var AwsClientInterface Client performing operations. */ private $client; /** @var string Name of the operation being paginated. */ private $operation; /** @var array Args for the operation. */ private $args; /** @var array Configuration for the paginator. */ private $config; /** @var Result Most recent result from the client. */ private $result; /** @var string|array Next token to use for pagination. */ private $nextToken; /** @var int Number of operations/requests performed. */ private $requestCount = 0; /** * @param AwsClientInterface $client * @param string $operation * @param array $args * @param array $config */ public function __construct( AwsClientInterface $client, $operation, array $args, array $config ) { $this->client = $client; $this->operation = $operation; $this->args = $args; $this->config = $config; } /** * Runs a paginator asynchronously and uses a callback to handle results. * * The callback should have the signature: function (Aws\Result $result). * A non-null return value from the callback will be yielded by the * promise. This means that you can return promises from the callback that * will need to be resolved before continuing iteration over the remaining * items, essentially merging in other promises to the iteration. The last * non-null value returned by the callback will be the result that fulfills * the promise to any downstream promises. * * @param callable $handleResult Callback for handling each page of results. * The callback accepts the result that was * yielded as a single argument. If the * callback returns a promise, the promise * will be merged into the coroutine. * * @return Promise\Promise */ public function each(callable $handleResult) { return Promise\Coroutine::of(function () use ($handleResult) { $nextToken = null; do { $command = $this->createNextCommand($this->args, $nextToken); $result = (yield $this->client->executeAsync($command)); $nextToken = $this->determineNextToken($result); $retVal = $handleResult($result); if ($retVal !== null) { yield Promise\Create::promiseFor($retVal); } } while ($nextToken); }); } /** * Returns an iterator that iterates over the values of applying a JMESPath * search to each result yielded by the iterator as a flat sequence. * * @param string $expression JMESPath expression to apply to each result. * * @return \Iterator */ public function search($expression) { // Apply JMESPath expression on each result, but as a flat sequence. return flatmap($this, function (Result $result) use ($expression) { return (array) $result->search($expression); }); } /** * @return Result */ #[\ReturnTypeWillChange] public function current() { return $this->valid() ? $this->result : false; } #[\ReturnTypeWillChange] public function key() { return $this->valid() ? $this->requestCount - 1 : null; } #[\ReturnTypeWillChange] public function next() { $this->result = null; } #[\ReturnTypeWillChange] public function valid() { if ($this->result) { return true; } if ($this->nextToken || !$this->requestCount) { $this->result = $this->client->execute( $this->createNextCommand($this->args, $this->nextToken) ); $this->nextToken = $this->determineNextToken($this->result); $this->requestCount++; return true; } return false; } #[\ReturnTypeWillChange] public function rewind() { $this->requestCount = 0; $this->nextToken = null; $this->result = null; } private function createNextCommand(array $args, array $nextToken = null) { return $this->client->getCommand($this->operation, array_merge($args, ($nextToken ?: []))); } private function determineNextToken(Result $result) { if (!$this->config['output_token']) { return null; } if ($this->config['more_results'] && !$result->search($this->config['more_results']) ) { return null; } $nextToken = is_scalar($this->config['output_token']) ? [$this->config['input_token'] => $this->config['output_token']] : array_combine($this->config['input_token'], $this->config['output_token']); return array_filter(array_map(function ($outputToken) use ($result) { return $result->search($outputToken); }, $nextToken)); } }
Save