Just creating the publisher via session.commitTransaction or session.abortTransaction does validation checks immediately on the current state of the transaction. This should be deferred until the publisher subscribed to.

This would greatly simplify the use of transactions in the reactive streams api.