@@ -11,6 +11,9 @@ |
||
11 | 11 | return $redis; |
12 | 12 | } |
13 | 13 | |
14 | + /** |
|
15 | + * @param Closure $fnc |
|
16 | + */ |
|
14 | 17 | public function eavesdrop($opts = ['criteria' => 0, 'options' => 1], $fnc, $args = []) |
15 | 18 | { |
16 | 19 | if (isset($opts['readArgs']) && !$opts['readArgs']) { |
@@ -55,7 +55,9 @@ |
||
55 | 55 | |
56 | 56 | $onEnd = function () use ($serialized, $redisKey, $init) { |
57 | 57 | $diff = ceil((microtime(true) - $init) * 1000); |
58 | - if ($diff < 10) return; |
|
58 | + if ($diff < 10) { |
|
59 | + return; |
|
60 | + } |
|
59 | 61 | |
60 | 62 | $time = strtotime("+1 hour 00:00"); |
61 | 63 | $redis = $this->analyticalStore(); |
@@ -490,7 +490,7 @@ discard block |
||
490 | 490 | } |
491 | 491 | |
492 | 492 | /** |
493 | - * @return Cursor |
|
493 | + * @return Traversable |
|
494 | 494 | */ |
495 | 495 | protected function ensureCursor() |
496 | 496 | { |
@@ -534,7 +534,7 @@ discard block |
||
534 | 534 | } |
535 | 535 | |
536 | 536 | /** |
537 | - * @return array |
|
537 | + * @return string[] |
|
538 | 538 | */ |
539 | 539 | public function __sleep() |
540 | 540 | { |