(state: Transaction["Service"])
| 14568 | }) |
| 14569 | |
| 14570 | const isTransactionConsistent = (state: Transaction["Service"]) => { |
| 14571 | for (const [ref, { version }] of state.journal) { |
| 14572 | if (ref.version !== version) { |
| 14573 | return false |
| 14574 | } |
| 14575 | } |
| 14576 | return true |
| 14577 | } |
| 14578 | |
| 14579 | const awaitPendingTransaction = (state: Transaction["Service"]) => |
| 14580 | suspend(() => { |