---

schmidt-sebastian · web-flow · commit d618e64cc459 · 2018-01-23T16:49:45.000-08:00
yaml --- r: 8947 b: refs/heads/lesv-patch-1 c: 42ba222 h: refs/heads/master i: 8945: 6fb9321 8943: 12e5beb
diff --git a/[refs] b/[refs]
@@ -66,7 +66,7 @@ refs/tags/v0.22.0: 18b298fe4bfe8ec2f20b0e0bf7ffdcce5cc3c5fe
 refs/heads/vam-google-patch-1: d0c8fee3a4074d0bf7360ce8c4f7f7223d0ee7b9
 refs/heads/vam-google-patch-CODEOWNERS: 2ac1616e25229e51d08a984708ef1918f91a35ee
 refs/heads/danoscarmike-patch-1: 7342a9916bce4ed00002c7202e2a16c5d46afaea
-refs/heads/lesv-patch-1: 4ca5d564812da2688fca55a4c72b41c4a3391d21
+refs/heads/lesv-patch-1: 42ba22278d9f21e60346beec1b3f98f743dc10c3
 refs/heads/ml-update-branch: 079dd6610017f5c51b9d1938c12d6d55b61513cf
 refs/heads/vkedia-patch-2: 7d8241388a9769a5c069334761b06c7012c878e7
 refs/heads/vkedia-patch-3: 4d128043acaa7db9160faf439d2ca6104e8a88cb
diff --git a/branches/lesv-patch-1/google-cloud-firestore/src/test/java/com/google/cloud/firestore/TransactionTest.java b/branches/lesv-patch-1/google-cloud-firestore/src/test/java/com/google/cloud/firestore/TransactionTest.java
@@ -53,6 +53,7 @@
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.atomic.AtomicInteger;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
@@ -273,17 +274,19 @@ public void limitsRetriesWithSuccess() throws Exception {
         .when(firestoreMock)
         .sendRequest(requestCapture.capture(), Matchers.<UnaryCallable<Message, Message>>any());
 
+    final AtomicInteger retryCount = new AtomicInteger(1);
+
     ApiFuture<String> transaction =
         firestoreMock.runTransaction(
             new Transaction.Function<String>() {
               @Override
               public String updateCallback(Transaction transaction) {
-                return "foo";
+                return "foo" + retryCount.getAndIncrement();
               }
             },
             TransactionOptions.create(options.getExecutor(), 6));
 
-    assertEquals("foo", transaction.get());
+    assertEquals("foo6", transaction.get());
 
     List<Message> requests = requestCapture.getAllValues();
     assertEquals(12, requests.size());
