1: <?php
2: /**
3: * Copyright 2012-2014 Rackspace US, Inc.
4: *
5: * Licensed under the Apache License, Version 2.0 (the "License");
6: * you may not use this file except in compliance with the License.
7: * You may obtain a copy of the License at
8: *
9: * http://www.apache.org/licenses/LICENSE-2.0
10: *
11: * Unless required by applicable law or agreed to in writing, software
12: * distributed under the License is distributed on an "AS IS" BASIS,
13: * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14: * See the License for the specific language governing permissions and
15: * limitations under the License.
16: */
17:
18: namespace OpenCloud\Common\Http\Message;
19:
20: use Symfony\Component\EventDispatcher\EventSubscriberInterface;
21:
22: /**
23: * Description of RequestSubscriber
24: */
25: class RequestSubscriber implements EventSubscriberInterface
26: {
27: public static function getInstance()
28: {
29: return new self();
30: }
31:
32: public static function getSubscribedEvents()
33: {
34: return array(
35: 'curl.callback.progress' => 'doCurlProgress'
36: );
37: }
38:
39: /**
40: * @param $options
41: * @return mixed
42: * @codeCoverageIgnore
43: */
44: public function doCurlProgress($options)
45: {
46: $curlOptions = $options['request']->getCurlOptions();
47:
48: if ($curlOptions->hasKey('progressCallback')) {
49: return call_user_func($curlOptions->get('progressCallback'));
50: }
51: }
52: }
53: