mirror_php/guzzle
1
0
Fork 0
mirror of https://github.com/guzzle/guzzle.git synced 2025-02-24 10:03:27 +01:00
Code Issues Releases Wiki Activity

Using the original promise

Browse Source
This commit is contained in:
Michael Dowling 2014-10-02 14:51:19 -07:00
parent 0a8b197766
commit 10ba5b836e
1 changed files with 9 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/Client.php
View File

@ -298,39 +298,29 @@ class Client implements ClientInterface
RingFuture $response
) {
// Expect a response to be delivered to the future.
$deferred = FutureResponse::createDeferred();
//$deferred = FutureResponse::createDeferred();
// When the response promise is resolved, then resolve the future
// response promise.
$response = $response->then(function ($value) use ($trans, $deferred) {
$response = $response->then(function ($value) use ($trans) {
RingBridge::completeRingResponse(
$trans, $value, $this->messageFactory, $this->fsm
);
if ($trans->exception) {
$deferred->reject(
RequestException::wrapException($trans->request, $trans->exception)
);
} else {
$deferred->resolve($trans->response);
throw RequestException::wrapException($trans->request, $trans->exception);
} elseif ($trans->response) {
// If we know that the events were fired, then there's a problem.
throw RingBridge::getNoRingResponseException($trans->request);
}
return $trans->response;
});
// Create a future response that's hooked up to the ring future.
return new FutureResponse(
$deferred->promise(),
$response,
// Dereference function
function () use ($deferred, $response, $trans) {
function () use ($response) {
$response->deref();
// Throw an exception if present. You need to remove transaction
// exceptions to prevent them from being thrown.
if ($trans->exception) {
$deferred->reject(RequestException::wrapException($trans->request, $trans->exception));
} elseif ($trans->response) {
// Return the response if one was set on the transaction.
$deferred->resolve($trans->response);
}
// If we know that the events were fired, then there's a problem.
$deferred->reject(RingBridge::getNoRingResponseException($trans->request));
},
// Cancel function. Just proxy to the underlying future.
[$response, 'cancel']