Remove count of commits in SystemTestStateStoreFakeCommits

java/system-test/system-test-dsl/src/main/java/sleeper/systemtest/dsl/statestore/SystemTestStateStoreFakeCommits.java

@@ -18,36 +18,29 @@
 import sleeper.systemtest.dsl.SystemTestContext;
 import sleeper.systemtest.dsl.instance.SystemTestInstanceContext;
 
-import java.util.concurrent.atomic.AtomicInteger;
 import java.util.function.Function;
 import java.util.stream.Stream;
 
 public class SystemTestStateStoreFakeCommits {
 
     private final SystemTestInstanceContext instance;
     private final StateStoreCommitterDriver driver;
-    private final AtomicInteger commitsSent = new AtomicInteger();
 
     public SystemTestStateStoreFakeCommits(SystemTestContext context) {
         instance = context.instance();
         driver = context.instance().adminDrivers().stateStoreCommitter(context);
     }
 
     public SystemTestStateStoreFakeCommits sendBatched(Function<StateStoreCommitMessageFactory, Stream<StateStoreCommitMessage>> buildCommits) {
-        send(buildCommits.apply(messageFactory()));
+        driver.sendCommitMessages(buildCommits.apply(messageFactory()));
         return this;
     }
 
     public SystemTestStateStoreFakeCommits send(Function<StateStoreCommitMessageFactory, StateStoreCommitMessage> buildCommit) {
-        send(Stream.of(buildCommit.apply(messageFactory())));
+        driver.sendCommitMessages(Stream.of(buildCommit.apply(messageFactory())));
         return this;
     }
 
-    private void send(Stream<StateStoreCommitMessage> messages) {
-        driver.sendCommitMessages(messages
-                .peek(message -> commitsSent.incrementAndGet()));
-    }
-
     private StateStoreCommitMessageFactory messageFactory() {
         return new StateStoreCommitMessageFactory(instance.getTableStatus().getTableUniqueId());
     }