Complex async/control flow question - kysely transactions

await db.transaction().execute(async function(tx) {
  // I need to "send" this tx back to an effect to be used
  // then I need to "wait" here, until everyone is done using this `tx`
  // then I either commit or rollback the transaction, depending on if there errors in the Effect pipeline that used the `tx`
});