本文整理汇总了PHP中GuzzleHttp\Promise\unwrap函数的典型用法代码示例。如果您正苦于以下问题:PHP unwrap函数的具体用法?PHP unwrap怎么用?PHP unwrap使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了unwrap函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的PHP代码示例。
示例1: send
/**
* @inheritdoc
*/
public function send()
{
$body = ['aps' => []];
if ($this->messageData !== null) {
$body['aps'] = $this->messageData;
}
if ($this->messageText !== null) {
$body['aps']['alert'] = $this->messageText;
if (!isset($body['aps']['sound'])) {
$body['aps']['sound'] = 'default';
}
if (!isset($body['aps']['badge'])) {
$body['aps']['badge'] = 0;
}
}
$bodyData = json_encode($body);
$ok = [];
$promises = [];
foreach ($this->recipients as $recipient) {
$url = sprintf('/3/device/%s', $recipient);
$promises[] = $this->client->postAsync($url, ['body' => $bodyData])->then(function (ResponseInterface $response) use(&$ok, $recipient) {
if ($response->getStatusCode() == 200) {
// Set to OK if we received a 200
$ok[] = $recipient;
} else {
$this->failedRecipients[] = $recipient;
}
}, function () use($recipient) {
$this->failedRecipients[] = $recipient;
});
}
// Wait for all requests to complete
Promise\unwrap($promises);
return $ok;
}
开发者ID:pharmit,项目名称:push,代码行数:38,代码来源:ApplePushService.php
示例2: getAllProjects
public function getAllProjects()
{
$key = "{$this->cachePrefix}-all-projects";
if ($this->cache && ($projects = $this->cache->fetch($key))) {
return $projects;
}
$first = json_decode($this->client->get('projects.json', ['query' => ['limit' => 100]])->getBody(), true);
$projects = $first['projects'];
if ($first['total_count'] > 100) {
$requests = [];
for ($i = 100; $i < $first['total_count']; $i += 100) {
$requests[] = $this->client->getAsync('projects.json', ['query' => ['limit' => 100, 'offset' => $i]]);
}
/** @var Response[] $responses */
$responses = Promise\unwrap($requests);
$responseProjects = array_map(function (Response $response) {
return json_decode($response->getBody(), true)['projects'];
}, $responses);
$responseProjects[] = $projects;
$projects = call_user_func_array('array_merge', $responseProjects);
}
usort($projects, function ($projectA, $projectB) {
return strcasecmp($projectA['name'], $projectB['name']);
});
$this->cache && $this->cache->save($key, $projects);
return $projects;
}
开发者ID:stelsvitya,项目名称:server-manager,代码行数:27,代码来源:Projects.php
示例3: __invoke
/**
* __invoke.
*
* @param mixed $values
*
* @return $this
*/
public function __invoke($values)
{
$response = json_decode((string) $values->getBody());
// Return when empty response.
if (empty($response)) {
return $this;
}
// Process the response.
$this->process($response);
$promisses = [];
// Loop over all artist and create promisses
foreach ($this->getArtistsAlbumsList() as $artistEntity) {
$artistEntity = $artistEntity[0];
// Process offset value only one time.
if (isset($this->processedArtistsList[$artistEntity->id]) && $this->processedArtistsList[$artistEntity->id] === true) {
continue;
} else {
$getArtistRelatedArtists = 'artists/' . $artistEntity->id . '/related-artists';
$promisses[] = $this->client->getAsync($getArtistRelatedArtists)->then($this);
// <= re-use same object.
$this->processedArtistsList[$artistEntity->id] = true;
}
}
// Resolve promisses.
Promise\unwrap($promisses);
return $this;
}
开发者ID:websoftwares,项目名称:spotify-artist-album-overview,代码行数:34,代码来源:ArtistsHandler.php
示例4: foreach
function upload_async($objects = [])
{
if (empty($objects)) {
$this->error = ['message' => 'object array is empty'];
return NULL;
}
$promises = [];
foreach ($objects as $id => $object) {
// $key = 'data.txt', $body = 'Hello!'
// Executing an operation asynchronously returns a Promise object.
$promises[$id] = $this->s3_client->putObjectAsync(['Bucket' => $this->bucket, 'Key' => $object['key'], 'Body' => $object['body'], 'ContentType' => $object['content-type']]);
}
// Wait for the operation to complete to get the Result object.
try {
$results = Promise\unwrap($promises);
} catch (AwsException $e) {
// handle the error.
$error_msg = 'getAwsRequestId: ' . $e->getAwsRequestId() . ', getAwsErrorType:' . $e->getAwsErrorType() . ', getAwsErrorCode:' . $e->getAwsErrorCode() . "\n\n";
$error_msg .= $e->getMessage() . "\n";
$error_msg .= $e->getTraceAsString();
}
// if (!empty($this->error)) echo $error_msg['message']; else var_dump($results); die();
if (!empty($error_msg)) {
$this->error = ['message' => $error_msg];
return NULL;
}
$response = [];
foreach ($results as $id => $result) {
if (!empty($result['ObjectURL'])) {
$response[$id] = $result['ObjectURL'];
}
}
return $response;
}
开发者ID:RimeOfficial,项目名称:postmaster,代码行数:34,代码来源:Lib_s3_object.php
示例5: testGetProductsAsync
/**
* @covers Mozu\Api\Resources\Commerce\Catalog\Admin\ProductResource::getProducts
* @todo Implement testGetProducts().
*/
public function testGetProductsAsync()
{
$promises = ["product1" => $this->object->getProductAsync("AIRMOTION-SCIENCES-BSF09"), "product2" => $this->object->getProductAsync("AIRMOTION-SCIENCES-BSF12"), "product3" => $this->object->getProductAsync("AIRMOTION-SCIENCES-BSF15")];
$results = Promise\unwrap($promises);
$this->assertSame($results["product1"]->json()->productCode, "AIRMOTION-SCIENCES-BSF09");
$this->assertSame($results["product2"]->json()->productCode, "AIRMOTION-SCIENCES-BSF12");
$this->assertSame($results["product3"]->json()->productCode, "AIRMOTION-SCIENCES-BSF15");
}
开发者ID:sgorman,项目名称:mozu-php-sdk,代码行数:12,代码来源:ProductResourceTest.php
示例6: testEventDispatcherMulticlient
public function testEventDispatcherMulticlient()
{
$mockDispatcher = new \mock\Symfony\Component\EventDispatcher\EventDispatcherInterface();
$container = $this->getContainerForConfiguation('multiclient-config');
$container->set('event_dispatcher', $mockDispatcher);
$container->compile();
$this->if($client = $container->get('m6web_guzzlehttp'))->and($client2 = $container->get('m6web_guzzlehttp_myclient'))->and($promises = ['test' => $client->getAsync('http://httpbin.org'), 'test2' => $client->getAsync('http://httpbin.org/ip')])->and($rep = Promise\unwrap($promises))->and($client2->get('http://httpbin.org'))->then->mock($mockDispatcher)->call('dispatch')->exactly(3);
}
开发者ID:AlliterativeAnimals,项目名称:GuzzleHttpBundle,代码行数:8,代码来源:M6WebGuzzleHttpExtension.php
示例7: parseLists
/**
* 分析公告列表.
*
* @param string $content
* @return array
*/
protected function parseLists($content)
{
$rows = array_slice(HtmlDomParser::str_get_html($content)->find('table table[bordercolordark] tr'), 1, 5);
$result = $promises = [];
foreach ($rows as $row) {
$result[] = ['date' => trim($row->children(0)->plaintext), 'title' => html_entity_decode(trim($row->children(2)->plaintext), ENT_QUOTES, 'UTF-8')];
$promises[] = $this->client->getAsync(self::CONTENT, ['cookies' => $this->jar, 'query' => ['a_id' => substr(strrchr(strstr($row->find('a', 0)->outertext, '&system', true), '='), 1)]]);
}
$response = Promise\unwrap($promises);
for ($i = 0, $size = count($result); $i < $size; ++$i) {
$result[$i]['content'] = $this->parseContent($response[$i]->getBody()->getContents());
}
return $result;
}
开发者ID:BePsvPT,项目名称:CCU-Plus,代码行数:20,代码来源:Announcement.php
示例8: parseLists
/**
* 分析授課教材列表.
*
* @param $content
* @return array
*/
public function parseLists($content)
{
$rows = HtmlDomParser::str_get_html($content)->find('a[href]');
$result = $promises = [];
foreach ($rows as $row) {
$promises[] = $this->client->getAsync(self::CONTENT . $row->href, ['http_errors' => false, 'cookies' => $this->jar]);
}
$responses = Promise\unwrap($promises);
foreach ($responses as $response) {
if (200 === $response->getStatusCode()) {
$result = array_merge($result, $this->parseContent($response->getBody()->getContents()));
}
}
return $result;
}
开发者ID:BePsvPT,项目名称:CCU-Plus,代码行数:21,代码来源:Attachment.php
示例9: __invoke
/**
* __invoke.
*
* @param mixed $values
*
* @return $this
*/
public function __invoke($values)
{
// Get from previous handler the artists albums list.
$this->artistsAlbumsList = $values->getArtistsAlbumsList();
$promisses = [];
// Loop over the artists albums list creating promisses for each artist.
foreach ($this->artistsAlbumsList as $artistId => $artistAlbum) {
$artistsTopTracks = 'artists/' . $artistId . '/top-tracks?country=US';
$promisses[$artistId] = $this->client->getAsync($artistsTopTracks);
}
// Resolve all promisses.
$artistAlbums = Promise\unwrap($promisses);
// Process the result.
$this->process($artistAlbums);
return $this;
}
开发者ID:websoftwares,项目名称:spotify-artist-album-overview,代码行数:23,代码来源:AlbumsHandler.php
示例10: send
function send($requests)
{
// 1. send emails async
$this->CI->load->library('composer/lib_aws');
$ses_client = $this->CI->lib_aws->get_ses();
$promises = [];
foreach ($requests as $request) {
echo '(' . $request['request_id'] . ') Sending message: ' . $request['subject'] . ', to: ' . $request['to_email'] . PHP_EOL;
// @debug: send to *@users.noreply.rime.co
// $request['to_email'] = 'user-'.md5($request['to_email']).'@users.noreply.rime.co';
$raw_message = ses_raw_email($request);
// var_dump($raw_message); die();
$email = ['RawMessage' => array('Data' => $raw_message)];
$promises[$request['request_id']] = $ses_client->sendRawEmailAsync($email);
}
// Wait on promises to complete and return the results.
try {
$results = Promise\unwrap($promises);
} catch (AwsException $e) {
// handle the error.
$error_msg = 'getAwsRequestId: ' . $e->getAwsRequestId() . ', getAwsErrorType:' . $e->getAwsErrorType() . ', getAwsErrorCode:' . $e->getAwsErrorCode() . "\n\n";
$error_msg .= $e->getMessage() . "\n";
$error_msg .= $e->getTraceAsString();
}
if (!empty($results)) {
// 2. save messege_id
$message_sent_list = [];
foreach ($results as $request_id => $result) {
echo '(' . $request_id . ') statusCode: ' . $result['@metadata']['statusCode'] . ', MessageId: ' . $result['MessageId'] . PHP_EOL;
if (!empty($result['@metadata']['statusCode']) and $result['@metadata']['statusCode'] == 200 and !empty($result['MessageId'])) {
$ses_message_id = $result['MessageId'];
$message_sent_list[] = ['request_id' => $request_id, 'sent' => date('Y-m-d H:i:s'), 'ses_message_id' => $ses_message_id, 'archived' => date('Y-m-d H:i:s'), 'body_html' => NULL, 'body_text' => NULL];
}
}
// mark sent
if (!empty($message_sent_list)) {
$this->CI->model_archive->update_batch($message_sent_list);
}
}
if (!empty($error_msg)) {
$this->error = ['message' => $error_msg];
return NULL;
} else {
return TRUE;
}
}
开发者ID:RimeOfficial,项目名称:postmaster,代码行数:46,代码来源:Lib_archive.php
示例11: parseLists
/**
* 分析作業列表.
*
* @param string $content
* @return array
*/
protected function parseLists($content)
{
$rows = array_slice(HtmlDomParser::str_get_html($content)->find('table table tr'), 1);
$result = $promises['content'] = $promises['submitted'] = [];
foreach ($rows as $row) {
$id = substr(strrchr(strstr($row->children(2)->innertext, '&action', true), '='), 1);
$result[] = ['name' => trim($row->children(1)->plaintext), 'date' => trim($row->children(3)->plaintext)];
$promises['content'][] = $this->client->getAsync(self::LISTS, ['allow_redirects' => false, 'cookies' => $this->jar, 'query' => ['work_id' => $id, 'action' => 'showwork']]);
$promises['submitted'][] = $this->client->getAsync(self::LISTS, ['cookies' => $this->jar, 'query' => ['work_id' => $id, 'action' => 'seemywork']]);
}
$response['content'] = Promise\unwrap($promises['content']);
$response['submitted'] = Promise\unwrap($promises['submitted']);
for ($i = 0, $size = count($result); $i < $size; ++$i) {
$result[$i]['submitted'] = $this->parseSubmitted($response['submitted'][$i]->getBody()->getContents());
if ($response['content'][$i]->hasHeader('location')) {
$result[$i]['link'] = self::BASE_URL . '/' . $response['content'][$i]->getHeaderLine('location');
} else {
$result[$i]['content'] = $this->parseContent($response['content'][$i]->getBody()->getContents());
}
}
return array_reverse($result);
}
开发者ID:BePsvPT,项目名称:CCU-Plus,代码行数:28,代码来源:Homework.php
示例12: run
function run($startPage = 'http://streeteasy.com/for-sale/downtown/status:closed%7Clisted%3C1500')
{
$nextPage = $startPage;
$promise = [$this->http->requestAsync('GET', $nextPage)];
$urls = [];
$i = 0;
do {
$result = Promise\unwrap($promise);
$content = $result[0]->getBody();
$this->html->load($content);
$nextPage = $this->parseNextUrl($this->html);
$promise = [$this->http->requestAsync('GET', $nextPage)];
$urls = $this->parseUrls($this->html);
print_r($urls);
$this->parseDetails($urls);
echo "nextPage={$nextPage}\n";
if ($i++ >= 1) {
break;
}
} while ($nextPage);
return $this->details;
}
开发者ID:vmax44,项目名称:vmax.16mb.com,代码行数:22,代码来源:streeteasy.class.php
示例13: multiRequest
/**
* @inheritdoc
*/
public function multiRequest(array $urls)
{
$client = new Client();
$promises = array();
foreach ($urls as $urlName => $urlData) {
if (is_string($urlData)) {
$urlData = array($urlData, array());
}
$urlOptions = new Options($urlData[1]);
$method = $urlOptions->get('method', 'GET', 'up');
$args = $urlOptions->get('args');
$url = 'GET' === $method ? Url::addArg((array) $args, $urlData[0]) : $urlData[0];
$promises[$urlName] = $client->requestAsync($method, $url, $this->_getClientOptions($urlOptions, $method, $args));
}
$httpResults = Promise\unwrap($promises);
/** @var string $resName */
/** @var Response $httpResult */
$result = array();
foreach ($httpResults as $resName => $httpResult) {
$result[$resName] = array($httpResult->getStatusCode(), $httpResult->getHeaders(), $httpResult->getBody()->getContents());
}
return $result;
}
开发者ID:jbzoo,项目名称:http-client,代码行数:26,代码来源:Guzzle6.php
示例14: send
/**
* @inheritdoc
*/
public function send()
{
$body = ['data' => []];
if ($this->messageData !== null) {
$body['data'] = $this->messageData;
}
if ($this->messageText !== null) {
$body['data']['message'] = $this->messageText;
}
$ok = [];
$promises = [];
$recipients_chunked = array_chunk($this->recipients, 1000);
foreach ($recipients_chunked as $recipients_part) {
$body['registration_ids'] = $recipients_part;
$promises[] = $this->client->postAsync('/gcm/send', ['body' => json_encode($body)])->then(function (ResponseInterface $response) use(&$ok, $recipients_part) {
if ($response->getStatusCode() == 200) {
// Set to OK if we received a 200
$contents = json_decode($response->getBody()->getContents(), true);
$results = $contents['results'];
foreach ($recipients_part as $idx => $recipient) {
if (isset($results[$idx]['message_id']) && !isset($results[$idx]['error'])) {
$ok[] = $recipient;
} else {
$this->failedRecipients[] = $recipient;
}
}
}
}, function () use($recipients_part) {
foreach ($recipients_part as $idx => $recipient) {
$this->failedRecipients[] = $recipient;
}
});
}
// Wait for all requests to complete
Promise\unwrap($promises);
return $ok;
}
开发者ID:pharmit,项目名称:push,代码行数:40,代码来源:GooglePushService.php
示例15: requestJsons
/**
* Create and send an HTTP request and return the decoded JSON response
* body
*
* @throws EWSClientError
*
* @param string $method
* HTTP method e.g. GET, POST, DELETE
* @param array $uris
* URI strings
* @param array $options
* Request options to apply
* @return mixed
* JSON decoded body from EWS
*/
public function requestJsons($method, $uris, array $options = [])
{
// Add the OAuth access token to the request headers
$options = array_merge($options, ['headers' => ['Authorization' => 'Bearer ' . $this->accessToken]]);
/** @var Promise\PromiseInterface[] $promises */
$promises = [];
$transactionIds = [];
$counter = 0;
foreach ($uris as $uri) {
$transactionIds[] = Uuid::uuid4()->toString();
$this->logRequest($transactionIds[$counter], $method, $uri, $options);
$promises[] = $this->http->requestAsync($method, $uri, $options);
}
try {
$responses = Promise\unwrap($promises);
$results = [];
$counter = 0;
foreach ($responses as $response) {
$this->logResponse($transactionIds[$counter], $method, $uris[$counter], $response);
$results[] = $this->handleResponse($response);
$counter++;
}
} catch (ClientException $e) {
throw new EWSClientError($e->getCode() . ' error', 0, null, []);
}
return $results;
}
开发者ID:CRUKorg,项目名称:cruk-event-sdk,代码行数:42,代码来源:EWSClient.php
示例16: importPaths
/**
* @param Finder $finder finder primmed with files to import
* @param OutputInterface $output output interfac
* @param string $host host to import into
* @param string $rewriteHost string to replace with value from $rewriteTo during loading
* @param string $rewriteTo string to replace value from $rewriteHost with during loading
* @param boolean $sync send requests syncronously
*
* @return void
*
* @throws MissingTargetException
*/
protected function importPaths(Finder $finder, OutputInterface $output, $host, $rewriteHost, $rewriteTo, $sync = false)
{
$promises = [];
foreach ($finder as $file) {
$doc = $this->frontMatter->parse($file->getContents());
$output->writeln("<info>Loading data from {$file}</info>");
if (!array_key_exists('target', $doc->getData())) {
throw new MissingTargetException('Missing target in \'' . $file . '\'');
}
$targetUrl = sprintf('%s%s', $host, $doc->getData()['target']);
$promises[] = $this->importResource($targetUrl, (string) $file, $output, $doc, $host, $rewriteHost, $rewriteTo, $sync);
}
try {
Promise\unwrap($promises);
} catch (\GuzzleHttp\Exception\ClientException $e) {
// silently ignored since we already output an error when the promise fails
}
}
开发者ID:alebon,项目名称:import-export,代码行数:30,代码来源:ImportCommand.php
示例17: Client
<?php
require 'vendor/autoload.php';
use GuzzleHttp\Client;
use GuzzleHttp\Promise;
$client = new Client();
// Initiate each request but do not block
$promises = ['yahoo' => $client->getAsync('http://www.yahoo.co.jp/'), 'passmarket' => $client->getAsync('http://passmarket.yahoo.co.jp/')];
// Wait on all of the requests to complete.
$results = Promise\unwrap($promises);
echo $results['yahoo']->getBody();
echo $results['passmarket']->getBody();
开发者ID:shinji62,项目名称:php-guzzle,代码行数:12,代码来源:index.php
示例18: sendRequests
/**
* Send awaiting requests
*/
protected function sendRequests()
{
if (count($this->promises) === count($this->filterSources(Source::STATUS_WAITING))) {
$toSend = [];
foreach ($this->promises as $key => $promise) {
if (count($toSend) === $this->concurrency) {
break;
}
$toSend[$key] = $promise;
unset($this->promises[$key]);
}
if (empty($toSend)) {
return;
}
$this->log('Sending awaiting requests');
$responses = Promise\unwrap($toSend);
foreach ($responses as $key => $response) {
$this->sources[$key]->response($response);
}
}
}
开发者ID:kminek,项目名称:comment-scraper,代码行数:24,代码来源:Scraper.php
示例19: send
/**
* Send the request
*
* @param $promises
* @param bool $isRelationAction
*
* @return array|bool|\Illuminate\Support\Collection
*/
protected function send($promises, $isRelationAction = false)
{
try {
return $results = Promise\unwrap($promises);
} catch (RequestException $e) {
print_r($e->getRequest()->getMethod() . ' ' . (string) $e->getRequest()->getUri() . PHP_EOL);
print_r(json_decode($e->getRequest()->getBody(), true));
print_r(json_decode($e->getResponse()->getBody(), true));
return false;
}
}
开发者ID:wpsinc,项目名称:wps-php-sdk,代码行数:19,代码来源:RequestBuilder.php
示例20: getAsync
/**
* Выполнение ассинхронных запросов
* @param $requests
* @return GisResponse[]
* @throws GisRequestException
*/
public function getAsync($requests)
{
$result = [];
$index = 0;
// разбиваем по 10 запросов
foreach (array_chunk($requests, 10) as $chunk) {
$promises = [];
foreach ($chunk as $request) {
/** @var $params BaseParams */
$params = $request['params'];
$params->setKey($this->apiKey);
$promises[$index] = $this->client->getAsync($request['url'], ['query' => $params->toArray()]);
$index++;
}
foreach (Promise\unwrap($promises) as $i => $response) {
$result[$i] = $this->formatResponse($response);
}
//Пауза нужна, иначе блочат ключ
// @todo продумать задержки :-(
sleep(1);
}
return $result;
}
开发者ID:akeinhell,项目名称:2gis-api,代码行数:29,代码来源:Api2Gis.php
注:本文中的GuzzleHttp\Promise\unwrap函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论