@@ -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 | |
@@ -121,7 +121,7 @@ |
||
| 121 | 121 | 'namespace' => ['href' => (string) $request->getUri()->withPath('/api/v1/namespaces/'.$namespace)], |
| 122 | 122 | 'collection' => ['href' => (string) $request->getUri()->withPath('/api/v1/namespaces/'.$namespace.'/collections/'.$collection)], |
| 123 | 123 | 'endpoint' => ['href' => (string) $request->getUri()->withPath('/api/v1/namespaces/'.$namespace.'/collections/'.$collection.'/endpoints/'.$endpoint)], |
| 124 | - ], |
|
| 124 | + ], |
|
| 125 | 125 | 'namespace' => $namespace, |
| 126 | 126 | 'collection' => $collection, |
| 127 | 127 | 'endpoint' => $endpoint, |
@@ -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 | { |