( graph: Graph<TSchema>, command: AsyncQuery, )
| 190 | } |
| 191 | |
| 192 | function* handleAsyncQuery<TSchema extends GraphSchema>( |
| 193 | graph: Graph<TSchema>, |
| 194 | command: AsyncQuery, |
| 195 | ) { |
| 196 | const steps = createStepsFromJSON(command.steps); |
| 197 | const traverser = createTraverser(steps); |
| 198 | for (const path of traverser.traverse(graph, [])) { |
| 199 | yield jsonClone(path) as TraversalPathJSON | StoredEdge | StoredVertex; |
| 200 | } |
| 201 | } |
| 202 | |
| 203 | function* handleAsyncTransaction<TSchema extends GraphSchema>( |
| 204 | graph: Graph<TSchema>, |
no test coverage detected