@@ -2,10 +2,10 @@ |
||
| 2 | 2 | |
| 3 | 3 | namespace h4kuna\Fio\Request; |
| 4 | 4 | |
| 5 | -use GuzzleHttp, |
|
| 6 | - h4kuna\Fio, |
|
| 7 | - h4kuna\Fio\Response\Pay, |
|
| 8 | - Nette\Utils; |
|
| 5 | +use GuzzleHttp; |
|
| 6 | +use h4kuna\Fio; |
|
| 7 | +use h4kuna\Fio\Response\Pay; |
|
| 8 | +use Nette\Utils; |
|
| 9 | 9 | |
| 10 | 10 | class Queue implements IQueue |
| 11 | 11 | { |
@@ -25,6 +25,9 @@ discard block |
||
| 25 | 25 | /** @var string */ |
| 26 | 26 | private $tempDir; |
| 27 | 27 | |
| 28 | + /** |
|
| 29 | + * @param string $tempDir |
|
| 30 | + */ |
|
| 28 | 31 | public function __construct($tempDir) |
| 29 | 32 | { |
| 30 | 33 | $this->tempDir = $tempDir; |
@@ -90,7 +93,7 @@ discard block |
||
| 90 | 93 | |
| 91 | 94 | /** |
| 92 | 95 | * @param $token |
| 93 | - * @param $fallback |
|
| 96 | + * @param \Closure $fallback |
|
| 94 | 97 | * @param string $action |
| 95 | 98 | * @return GuzzleHttp\Psr7\Stream |
| 96 | 99 | * @throws Fio\QueueLimitException |
@@ -142,6 +145,9 @@ discard block |
||
| 142 | 145 | } |
| 143 | 146 | } |
| 144 | 147 | |
| 148 | + /** |
|
| 149 | + * @param string $filename |
|
| 150 | + */ |
|
| 145 | 151 | private static function sleep($filename) |
| 146 | 152 | { |
| 147 | 153 | $criticalTime = time() - filemtime($filename); |
@@ -164,6 +170,9 @@ discard block |
||
| 164 | 170 | return self::$tokens[$key]; |
| 165 | 171 | } |
| 166 | 172 | |
| 173 | + /** |
|
| 174 | + * @param string $filename |
|
| 175 | + */ |
|
| 167 | 176 | private static function safeProtocol($filename) |
| 168 | 177 | { |
| 169 | 178 | return Utils\SafeStream::PROTOCOL . '://' . $filename; |