Remove redundant thenApply call in TransactionCoordiantor
Change-Id: I96d8a06ddef7b1bd9068a589bfa780e82c5dd556
Showing
1 changed file
with
1 additions
and
1 deletions
... | @@ -53,7 +53,7 @@ public class TransactionCoordinator { | ... | @@ -53,7 +53,7 @@ public class TransactionCoordinator { |
53 | : transactions.put(transactionId, Transaction.State.ROLLINGBACK) | 53 | : transactions.put(transactionId, Transaction.State.ROLLINGBACK) |
54 | .thenCompose(v -> doRollback(transactionParticipants)) | 54 | .thenCompose(v -> doRollback(transactionParticipants)) |
55 | .thenApply(v -> null)) | 55 | .thenApply(v -> null)) |
56 | - .thenCompose(v -> transactions.remove(transactionId).thenApply(u -> null)) | 56 | + .thenCompose(v -> transactions.remove(transactionId)) |
57 | .thenApply(v -> null); | 57 | .thenApply(v -> null); |
58 | } | 58 | } |
59 | 59 | ... | ... |
-
Please register or login to post a comment