1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
<?php
/**
* PHP OpenCloud library.
*
* @copyright 2014 Rackspace Hosting, Inc. See LICENSE for information.
* @license https://www.apache.org/licenses/LICENSE-2.0
* @author Jamie Hannaford <jamie.hannaford@rackspace.com>
* @author Glen Campbell <glen.campbell@rackspace.com>
*/
namespace OpenCloud\Common\Http\Message;
use Guzzle\Common\Event;
use Guzzle\Http\Message\EntityEnclosingRequest;
use OpenCloud\Common\Constants\Header;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
/**
* Description of RequestSubscriber
*/
class RequestSubscriber implements EventSubscriberInterface
{
public static function getInstance()
{
return new self();
}
public static function getSubscribedEvents()
{
return array(
'curl.callback.progress' => 'doCurlProgress'
);
}
/**
* @param $options
* @return mixed
* @codeCoverageIgnore
*/
public function doCurlProgress($options)
{
$curlOptions = $options['request']->getCurlOptions();
if ($curlOptions->hasKey('progressCallback')) {
return call_user_func($curlOptions->get('progressCallback'));
} else {
echo sprintf(
"Download size: [%d]\nDownloaded: [%d]\nUpload size: [%d]\nUploaded: [%d]\n",
$options['download_size'],
$options['downloaded'],
$options['upload_size'],
$options['uploaded']
);
}
}
}
|
