From 1738b30ec16cdf28c390d6998aff492c320cbde4 Mon Sep 17 00:00:00 2001
From: OZGCloud <ozgcloud@mgm-tp.com>
Date: Thu, 23 Nov 2023 13:48:07 +0100
Subject: [PATCH] remove buffer
---
.../de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java b/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java
index c9dc311..e4f73fc 100644
--- a/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java
+++ b/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java
@@ -76,7 +76,7 @@ public class GrpcFileUploadUtils {
FileSender(BiFunction<byte[], Integer, Q> chunkBuilder, Function<StreamObserver<S>, CallStreamObserver<Q>> reqObserverBuilder,
InputStream inputStream) {
this.chunkBuilder = chunkBuilder;
- this.inputStream = IOUtils.buffer(inputStream, CHUNK_SIZE);
+ this.inputStream = inputStream;
this.reqObserverBuilder = reqObserverBuilder;
this.streamReader = new StreamReader(this.inputStream);
@@ -214,7 +214,7 @@ public class GrpcFileUploadUtils {
try {
lastReadSize = inStream.read(buffer, 0, CHUNK_SIZE);
} catch (IOException e) {
- throw new TechnicalException("Error on sending a single chunk", e);
+ throw new TechnicalException("Error on reading a single chunk", e);
}
}
}
--
GitLab