mirror of
https://github.com/guzzle/guzzle.git
synced 2025-02-24 10:03:27 +01:00
Adding end event to events and updating creating cancelled future responses
This commit is contained in:
parent
87470bf043
commit
bc63e5f747
@ -1,6 +1,7 @@
|
||||
<?php
|
||||
namespace GuzzleHttp\Message;
|
||||
|
||||
use GuzzleHttp\Exception\CancelledRequestException;
|
||||
use GuzzleHttp\Exception\RequestException;
|
||||
use React\Promise\RejectedPromise;
|
||||
|
||||
@ -19,6 +20,15 @@ class CancelledFutureResponse extends FutureResponse
|
||||
*/
|
||||
public static function fromException(RequestException $e)
|
||||
{
|
||||
if (!($e instanceof CancelledRequestException)) {
|
||||
$e = new CancelledRequestException(
|
||||
$e->getMessage(),
|
||||
$e->getRequest(),
|
||||
$e->getResponse(),
|
||||
$e
|
||||
);
|
||||
}
|
||||
|
||||
return new self(new RejectedPromise($e));
|
||||
}
|
||||
|
||||
|
@ -325,9 +325,12 @@ class MessageFactory implements MessageFactoryInterface
|
||||
throw new Iae('events must be an array');
|
||||
}
|
||||
|
||||
$this->attachListeners($request, $this->prepareListeners($value,
|
||||
['before', 'complete', 'error', 'progress']
|
||||
));
|
||||
$this->attachListeners($request,
|
||||
$this->prepareListeners(
|
||||
$value,
|
||||
['before', 'complete', 'error', 'progress', 'end']
|
||||
)
|
||||
);
|
||||
break;
|
||||
|
||||
case 'subscribers':
|
||||
|
Loading…
x
Reference in New Issue
Block a user