@@ -144,7 +144,7 @@ discard block |
||
| 144 | 144 | /** |
| 145 | 145 | * Sets a limit of simultaneously executing tasks |
| 146 | 146 | * @param integer $n Natural number or -1 (no limit) |
| 147 | - * @return this |
|
| 147 | + * @return ComplexJob |
|
| 148 | 148 | */ |
| 149 | 149 | public function maxConcurrency($n = -1) { |
| 150 | 150 | $this->maxConcurrency = $n; |
@@ -216,7 +216,7 @@ discard block |
||
| 216 | 216 | /** |
| 217 | 217 | * Sets a callback which is going to be fired always when we have a room for more jobs |
| 218 | 218 | * @param callable $cb Callback |
| 219 | - * @return this |
|
| 219 | + * @return ComplexJob |
|
| 220 | 220 | */ |
| 221 | 221 | public function more($cb = null) { |
| 222 | 222 | if ($cb !== null) { |
@@ -182,7 +182,7 @@ discard block |
||
| 182 | 182 | * @param boolean $reply Is an answer expected? |
| 183 | 183 | * @param callable $sentcb Sent callback |
| 184 | 184 | * @callback $sentcb ( ) |
| 185 | - * @return callable |
|
| 185 | + * @return \Closure |
|
| 186 | 186 | */ |
| 187 | 187 | protected function requestCbProducer($opcode, $data, $reply = false, $sentcb = null) { |
| 188 | 188 | return function ($conn) use ($opcode, $data, $reply, $sentcb) { |
@@ -1482,6 +1482,9 @@ discard block |
||
| 1482 | 1482 | }, $session['conn']); |
| 1483 | 1483 | } |
| 1484 | 1484 | |
| 1485 | + /** |
|
| 1486 | + * @param \Closure $cb |
|
| 1487 | + */ |
|
| 1485 | 1488 | public function sasl_scrum_sha1_conversation($dbname, $query, $cb, $conn = null) |
| 1486 | 1489 | { |
| 1487 | 1490 | if ($this->safeMode) { |