From b19ca1f2bc83c1cb4aeeabc22dda07275d92e76c Mon Sep 17 00:00:00 2001
From: Suyash Garg <suyashgargsfam@gmail.com>
Date: Fri, 2 Nov 2018 10:49:18 +0100
Subject: [PATCH] Don't find min as it is checked already

---
 .../nakadi/service/subscription/state/PartitionData.java      | 4 ----
 .../nakadi/service/subscription/state/StreamingState.java     | 2 +-
 2 files changed, 1 insertion(+), 5 deletions(-)

diff --git a/src/main/java/org/zalando/nakadi/service/subscription/state/PartitionData.java b/src/main/java/org/zalando/nakadi/service/subscription/state/PartitionData.java
index 8d159eeb1d..dda6679bf7 100644
--- a/src/main/java/org/zalando/nakadi/service/subscription/state/PartitionData.java
+++ b/src/main/java/org/zalando/nakadi/service/subscription/state/PartitionData.java
@@ -120,10 +120,6 @@ public List<ConsumedEvent> extractMaxEvents(final long currentTimeMillis, final
         return result;
     }
 
-    public int getNumberOfUnsentEvents() {
-        return this.nakadiEvents.size();
-    }
-
     int getKeepAliveInARow() {
         return keepAliveInARow;
     }
diff --git a/src/main/java/org/zalando/nakadi/service/subscription/state/StreamingState.java b/src/main/java/org/zalando/nakadi/service/subscription/state/StreamingState.java
index 0f3808f15b..008517c4a6 100644
--- a/src/main/java/org/zalando/nakadi/service/subscription/state/StreamingState.java
+++ b/src/main/java/org/zalando/nakadi/service/subscription/state/StreamingState.java
@@ -261,7 +261,7 @@ private void streamToOutput(final boolean streamTimeoutReached) {
 
             long deltaSize = heaviestPartition.getValue().getBytesInMemory();
             final List<ConsumedEvent> events = heaviestPartition.getValue().extractMaxEvents(currentTimeMillis,
-                    Math.min((int) getMessagesAllowedToSend(), heaviestPartition.getValue().getNumberOfUnsentEvents()));
+                    (int) getMessagesAllowedToSend());
             deltaSize -= heaviestPartition.getValue().getBytesInMemory();
 
             sentSomething = true;