@@ -26,6 +26,9 @@ discard block |
||
| 26 | 26 | /** @var string */ |
| 27 | 27 | private $tempDir; |
| 28 | 28 | |
| 29 | + /** |
|
| 30 | + * @param string $tempDir |
|
| 31 | + */ |
|
| 29 | 32 | public function __construct($tempDir) |
| 30 | 33 | { |
| 31 | 34 | $this->tempDir = $tempDir; |
@@ -60,7 +63,7 @@ discard block |
||
| 60 | 63 | /** |
| 61 | 64 | * @param $token |
| 62 | 65 | * @param string $url |
| 63 | - * @return mixed|string |
|
| 66 | + * @return GuzzleHttp\Psr7\Stream |
|
| 64 | 67 | * @throws Fio\QueueLimitException |
| 65 | 68 | * @throws Fio\ServiceUnavailableException |
| 66 | 69 | */ |
@@ -91,7 +94,7 @@ discard block |
||
| 91 | 94 | |
| 92 | 95 | /** |
| 93 | 96 | * @param $token |
| 94 | - * @param $fallback |
|
| 97 | + * @param \Closure $fallback |
|
| 95 | 98 | * @param string $action |
| 96 | 99 | * @return GuzzleHttp\Psr7\Stream |
| 97 | 100 | * @throws Fio\QueueLimitException |
@@ -154,6 +157,9 @@ discard block |
||
| 154 | 157 | } |
| 155 | 158 | } |
| 156 | 159 | |
| 160 | + /** |
|
| 161 | + * @param string $filename |
|
| 162 | + */ |
|
| 157 | 163 | private static function sleep($filename) |
| 158 | 164 | { |
| 159 | 165 | $criticalTime = time() - filemtime($filename); |
@@ -176,6 +182,9 @@ discard block |
||
| 176 | 182 | return self::$tokens[$key]; |
| 177 | 183 | } |
| 178 | 184 | |
| 185 | + /** |
|
| 186 | + * @param string $filename |
|
| 187 | + */ |
|
| 179 | 188 | private static function safeProtocol($filename) |
| 180 | 189 | { |
| 181 | 190 | return Utils\SafeStream::PROTOCOL . '://' . $filename; |