@@ -50,11 +50,11 @@ discard block |
||
50 | 50 | * @since 7.0.0 |
51 | 51 | */ |
52 | 52 | function readObject($urn) { |
53 | - return SeekableHttpStream::open(function ($range) use ($urn) { |
|
53 | + return SeekableHttpStream::open(function($range) use ($urn) { |
|
54 | 54 | $command = $this->getConnection()->getCommand('GetObject', [ |
55 | 55 | 'Bucket' => $this->bucket, |
56 | 56 | 'Key' => $urn, |
57 | - 'Range' => 'bytes=' . $range, |
|
57 | + 'Range' => 'bytes='.$range, |
|
58 | 58 | ]); |
59 | 59 | $request = \Aws\serialize($command); |
60 | 60 | $headers = []; |
@@ -83,7 +83,7 @@ discard block |
||
83 | 83 | */ |
84 | 84 | function writeObject($urn, $stream) { |
85 | 85 | $count = 0; |
86 | - $countStream = CallbackWrapper::wrap($stream, function ($read) use (&$count) { |
|
86 | + $countStream = CallbackWrapper::wrap($stream, function($read) use (&$count) { |
|
87 | 87 | $count += $read; |
88 | 88 | }); |
89 | 89 |
@@ -62,7 +62,7 @@ discard block |
||
62 | 62 | ]); |
63 | 63 | |
64 | 64 | SeekableHttpStream::registerIfNeeded(); |
65 | - return fopen(SeekableHttpStream::PROTOCOL . '://', 'r', false, $context); |
|
65 | + return fopen(SeekableHttpStream::PROTOCOL.'://', 'r', false, $context); |
|
66 | 66 | } |
67 | 67 | |
68 | 68 | /** @var resource */ |
@@ -77,7 +77,7 @@ discard block |
||
77 | 77 | private $offset = 0; |
78 | 78 | |
79 | 79 | private function reconnect(int $start) { |
80 | - $range = $start . '-'; |
|
80 | + $range = $start.'-'; |
|
81 | 81 | if ($this->current != null) { |
82 | 82 | fclose($this->current); |
83 | 83 | } |
@@ -89,7 +89,7 @@ discard block |
||
89 | 89 | } |
90 | 90 | |
91 | 91 | $responseHead = stream_get_meta_data($this->current)['wrapper_data']; |
92 | - $rangeHeaders = array_values(array_filter($responseHead, function ($v) { |
|
92 | + $rangeHeaders = array_values(array_filter($responseHead, function($v) { |
|
93 | 93 | return preg_match('#^content-range:#i', $v) === 1; |
94 | 94 | })); |
95 | 95 | if (!$rangeHeaders) { |