@@ -69,7 +69,7 @@ |
||
69 | 69 | /** |
70 | 70 | * Set options. |
71 | 71 | * |
72 | - * @param iterable $config |
|
72 | + * @param iterable|null $config |
|
73 | 73 | */ |
74 | 74 | public function setOptions(?Iterable $config): ApiClient |
75 | 75 | { |
@@ -218,6 +218,7 @@ |
||
218 | 218 | |
219 | 219 | /** |
220 | 220 | * Verify response. |
221 | + * @param \Psr\Http\Message\ResponseInterface $response |
|
221 | 222 | */ |
222 | 223 | protected function getResponse($response): array |
223 | 224 | { |
@@ -296,6 +296,7 @@ |
||
296 | 296 | |
297 | 297 | /** |
298 | 298 | * Process ruleset. |
299 | + * @return string |
|
299 | 300 | */ |
300 | 301 | protected function rewrite($value, array $ruleset) |
301 | 302 | { |
@@ -52,6 +52,8 @@ |
||
52 | 52 | |
53 | 53 | /** |
54 | 54 | * watch all. |
55 | + * @param integer $offset |
|
56 | + * @param integer $limit |
|
55 | 57 | */ |
56 | 58 | public function watch(?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator |
57 | 59 | { |
@@ -180,6 +180,8 @@ |
||
180 | 180 | |
181 | 181 | /** |
182 | 182 | * Change stream. |
183 | + * @param integer $offset |
|
184 | + * @param integer $limit |
|
183 | 185 | */ |
184 | 186 | public function watch(ResourceNamespaceInterface $namespace, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator |
185 | 187 | { |
@@ -18,7 +18,6 @@ |
||
18 | 18 | use Psr\Http\Server\MiddlewareInterface; |
19 | 19 | use Psr\Http\Server\RequestHandlerInterface; |
20 | 20 | use Tubee\Rest\Exception; |
21 | -use Zend\Diactoros\Response; |
|
22 | 21 | |
23 | 22 | class QueryDecoder implements MiddlewareInterface |
24 | 23 | { |
@@ -18,7 +18,6 @@ |
||
18 | 18 | use Tubee\Resource\AbstractResource; |
19 | 19 | use Tubee\Resource\AttributeResolver; |
20 | 20 | use Tubee\V8\Engine as V8Engine; |
21 | -use Tubee\Workflow\Map; |
|
22 | 21 | use Tubee\Workflow\WorkflowInterface; |
23 | 22 | use V8Js; |
24 | 23 |
@@ -146,6 +146,8 @@ |
||
146 | 146 | |
147 | 147 | /** |
148 | 148 | * Change stream. |
149 | + * @param integer $offset |
|
150 | + * @param integer $limit |
|
149 | 151 | */ |
150 | 152 | public function watch(EndpointInterface $endpoint, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator |
151 | 153 | { |
@@ -191,6 +191,7 @@ discard block |
||
191 | 191 | |
192 | 192 | /** |
193 | 193 | * Get all. |
194 | + * @param Closure $build |
|
194 | 195 | */ |
195 | 196 | public function getAllFrom(Collection $collection, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null, ?Closure $build = null): Generator |
196 | 197 | { |
@@ -217,6 +218,7 @@ discard block |
||
217 | 218 | |
218 | 219 | /** |
219 | 220 | * Change stream. |
221 | + * @param Closure $build |
|
220 | 222 | */ |
221 | 223 | public function watchFrom(Collection $collection, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = [], ?Closure $build = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator |
222 | 224 | { |