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 c9dc311ec7d52bf106ab2eb174a77f583b7d0c74..e4f73fc9847f38167945e4bec194f84aa1ab244b 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); } } }