@@ -267,7 +267,7 @@ private void addUserCallback(int batchId, TaskCompletionSource<Void> userTask) {
267
267
public <TResult > void transaction (
268
268
AsyncQueue asyncQueue ,
269
269
ExponentialBackoff backoff ,
270
- TaskCompletionSource <TResult > txTaskSource ,
270
+ TaskCompletionSource <TResult > taskSource ,
271
271
Function <Transaction , Task <TResult >> updateFunction ,
272
272
int retries ) {
273
273
hardAssert (retries >= 0 , "Got negative number of retries for transaction." );
@@ -285,9 +285,9 @@ public void onComplete(@NonNull Task<TResult> userTask) {
285
285
if (!userTask .isSuccessful ()) {
286
286
if (retries > 0 && isRetryableTransactionError (userTask .getException ())) {
287
287
transaction (
288
- asyncQueue , backoff , txTaskSource , updateFunction , retries - 1 );
288
+ asyncQueue , backoff , taskSource , updateFunction , retries - 1 );
289
289
} else {
290
- txTaskSource .setException (userTask .getException ());
290
+ taskSource .setException (userTask .getException ());
291
291
}
292
292
} else {
293
293
transaction
@@ -298,17 +298,17 @@ public void onComplete(@NonNull Task<TResult> userTask) {
298
298
@ Override
299
299
public void onComplete (@ NonNull Task <Void > commitTask ) {
300
300
if (commitTask .isSuccessful ()) {
301
- txTaskSource .setResult (userTask .getResult ());
301
+ taskSource .setResult (userTask .getResult ());
302
302
} else if (retries > 0
303
303
&& isRetryableTransactionError (commitTask .getException ())) {
304
304
transaction (
305
305
asyncQueue ,
306
306
backoff ,
307
- txTaskSource ,
307
+ taskSource ,
308
308
updateFunction ,
309
309
retries - 1 );
310
310
} else {
311
- txTaskSource .setException (commitTask .getException ());
311
+ taskSource .setException (commitTask .getException ());
312
312
}
313
313
}
314
314
});
0 commit comments