Files
app-organization-portal/config/ldes-delta-pusher/dispatch.ts

13 lines
293 B
TypeScript

import { moveTriples } from "../support";
import { Changeset } from "../types";
export default async function dispatch(changesets: Changeset[]) {
for (const changeset of changesets) {
await moveTriples([
{
inserts: changeset.inserts,
deletes: changeset.deletes,
},
]);
}
}