From 040d09cfa6fc8b30c101b4ad6c1b4b4a738422ad Mon Sep 17 00:00:00 2001
From: Tadgh <garygrantgraham@gmail.com>
Date: Tue, 28 Sep 2021 16:43:29 -0400
Subject: [PATCH] Remvoe error in moving code over

---
 .../java/ca/uhn/fhir/jpa/dao/BaseTransactionProcessor.java   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/hapi-fhir-storage/src/main/java/ca/uhn/fhir/jpa/dao/BaseTransactionProcessor.java b/hapi-fhir-storage/src/main/java/ca/uhn/fhir/jpa/dao/BaseTransactionProcessor.java
index 2ded01a8341..efca7fb5346 100644
--- a/hapi-fhir-storage/src/main/java/ca/uhn/fhir/jpa/dao/BaseTransactionProcessor.java
+++ b/hapi-fhir-storage/src/main/java/ca/uhn/fhir/jpa/dao/BaseTransactionProcessor.java
@@ -397,9 +397,8 @@ public abstract class BaseTransactionProcessor {
 		List<RetriableBundleTask> getCalls = new ArrayList<>();
 		List<RetriableBundleTask> nonGetCalls = new ArrayList<>();
 
-		long getEntriesSize = requestEntries.stream().filter(entry -> myVersionAdapter.getEntryRequestVerb(myContext, entry).equalsIgnoreCase("GET")).count();
-		CountDownLatch completionLatch = new CountDownLatch((int) getEntriesSize);
-		for (int i=0; i<requestEntriesSize ; i++ ) {
+		CountDownLatch completionLatch = new CountDownLatch(requestEntriesSize);
+		for (int i=0; i< requestEntriesSize ; i++ ) {
 			IBase nextRequestEntry = requestEntries.get(i);
 			RetriableBundleTask retriableBundleTask = new RetriableBundleTask(completionLatch, theRequestDetails, responseMap, i, nextRequestEntry, theNestedMode);
 			if  (myVersionAdapter.getEntryRequestVerb(myContext, nextRequestEntry).equalsIgnoreCase("GET")) {