fix: add flush check in BulkWriter.sendBatchLocked() callback (#631)

googleapis · May 14, 2021 · ac3db81 · ac3db81
1 parent afa91ff
commit ac3db81
Showing 1 changed file with 4 additions and 2 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
@@ -988,8 +988,10 @@ private void sendBatchLocked(final BulkCommitBatch batch, final boolean flush) {
               new Runnable() {
                 @Override
                 public void run() {
-                  synchronized (lock) {
-                    scheduleCurrentBatchLocked(flush);
+                  if (flush) {
+                    synchronized (lock) {
+                      scheduleCurrentBatchLocked(/* flush= */ true);
+                    }
                   }
                 }
               },