( graph: Graph<TSchema>, command: AsyncCommand, )
| 178 | } |
| 179 | |
| 180 | export async function* handleAsyncCommand<TSchema extends GraphSchema>( |
| 181 | graph: Graph<TSchema>, |
| 182 | command: AsyncCommand, |
| 183 | ): AsyncIterable<TransportableValue> { |
| 184 | switch (command["@type"]) { |
| 185 | case "AsyncQuery": |
| 186 | return yield* handleAsyncQuery(graph, command); |
| 187 | case "AsyncTransaction": |
| 188 | return yield* handleAsyncTransaction(graph, command); |
| 189 | } |
| 190 | } |
| 191 | |
| 192 | function* handleAsyncQuery<TSchema extends GraphSchema>( |
| 193 | graph: Graph<TSchema>, |
no test coverage detected