Struct SharedTx

internal/riverinternaltest/sharedtx/shared_tx.go:28–31

SharedTx can be used to wrap a test transaction in cases where multiple callers may want to access it concurrently during the course of a single test case. Normally this is not allowed and an access will error with "conn busy" if another caller is already using it. This is a test-only construct bec

// encountered by use of concurrent accesses will be more difficult to debug
// than otherwise, so it's better to not go there at all if it can be avoided.
type SharedTx struct {
	inner pgx.Tx
	wait  chan struct{}
}

func NewSharedTx(tx pgx.Tx) *SharedTx {
	wait := make(chan struct{}, 1)