@@ -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) { |