diff --git a/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/common/grpc/GrpcResponseBatchStreamer.java b/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/common/grpc/GrpcResponseBatchStreamer.java index 7d876064b1ae2e92f20f037f7a6a9fa94d4bf1f3..bf1914ecf735c677a78ec2af4e3516f5aa5c4427 100644 --- a/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/common/grpc/GrpcResponseBatchStreamer.java +++ b/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/common/grpc/GrpcResponseBatchStreamer.java @@ -60,7 +60,7 @@ public class GrpcResponseBatchStreamer<ElemType, ResType> { } private boolean batchIsFull() { - return responseBuilder.getElementCount() == batchSize; + return responseBuilder.getElementCount() >= batchSize; } public void finish() {