in src/stm.ts [196:215]
public addChanges(cmp: Builder.ComparatorBuilder) {
const clauses: RPC.IRequestOp[] = [];
this.ops.forEach(op => {
switch (op.op) {
case WriteKind.Write:
clauses.push({ request_put: op.req });
break;
case WriteKind.DeleteKey:
clauses.push({ request_delete_range: op.req });
break;
case WriteKind.DeleteRange:
clauses.push({ request_delete_range: op.req });
break;
default:
throw new ClientRuntimeError(`Unexpected write op ${JSON.stringify(op)}`);
}
});
cmp.then(...clauses);
}