Method OnComplete

core/db_tx.go:85–90

OnComplete registers the provided callback that will be invoked once the related transaction ends (either completes successfully or rollbacked with an error). The callback receives the transaction error (if any) as its argument. Any additional errors returned by the OnComplete callbacks will be joi

(fn func(txErr error) error)

// Any additional errors returned by the OnComplete callbacks will be
// joined together with txErr when returning the final transaction result.
func (a *TxAppInfo) OnComplete(fn func(txErr error) error) {
	a.mu.Lock()
	defer a.mu.Unlock()

	a.afterFuncs = append(a.afterFuncs, fn)
}

// note: can be called only once because TxAppInfo is cleared
func (a *TxAppInfo) runAfterFuncs(txErr error) error {