resolve comments

googleapis · Apr 28, 2021 · 114fc26 · 114fc26
1 parent 643532d
commit 114fc26
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/BulkWriter.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/BulkWriter.java
@@ -724,7 +724,7 @@ public void run() {
       }
     }
 
-    ApiFuture<WriteResult> transformedFuture =
+    ApiFuture<WriteResult> processedOperationFuture =
         ApiFutures.transformAsync(
             operation.getFuture(),
             new ApiAsyncFunction<WriteResult, WriteResult>() {
@@ -733,10 +733,11 @@ public ApiFuture<WriteResult> apply(WriteResult result) throws Exception {
                 processBufferedOperations();
                 return ApiFutures.immediateFuture(result);
               }
-            });
+            },
+            MoreExecutors.directExecutor());
 
     return ApiFutures.catchingAsync(
-        transformedFuture,
+        processedOperationFuture,
         ApiException.class,
         new ApiAsyncFunction<ApiException, WriteResult>() {
           public ApiFuture<WriteResult> apply(ApiException e) throws Exception {