747
prevState := u.setState(stateProvisionallyCompleted)
748
effects.OnAfterCommit(func(context.Context) {
749
>
if u.state != stateProvisionallyCompleted {
update.go
750
return
751
}
752
754
>
u.setState(stateCompleted)
755
>
outcome := updatepb.Outcome{
756
>
Value: &updatepb.Outcome_Failure{Failure: rejectionFailure},
757
>
}
758
>
u.accepted.(*future.FutureImpl[*failurepb.Failure]).Set(rejectionFailure, nil)
759
>
u.outcome.(*future.FutureImpl[*updatepb.Outcome]).Set(&outcome, nil)
760
>
u.onComplete()
761
})
762
effects.OnAfterRollback(func(context.Context) {