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