@@ -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; |