sarvagya agarwal
var firstChunk = true val fileChunks = flow { if(firstChunk) { val metadata = MetaData.newBuilder() .setPath(file.path) .setConvertToPdf(BoolValue.of(convertToPdf)) .build() emit(FileUploadRequest.newBuilder().setMetadata(metadata).build()) firstChunk = false } else { while(true) { val size = inputStream.read(chunk) if(size <= 0) break val fileChunk = FileChunk.newBuilder() .setData(ByteString.copyFrom(chunk, 0, size)).build() emit(FileUploadRequest.newBuilder().setContent(fileChunk).build()) } } }
Robert Williams
firstChunk
flow
flow { val metadata = MetaData.newBuilder() .setPath(file.path) .setConvertToPdf(BoolValue.of(convertToPdf)) .build() emit(FileUploadRequest.newBuilder().setMetadata(metadata).build()) while(true) { val size = inputStream.read(chunk) if(size <= 0) break val fileChunk = FileChunk.newBuilder() .setData(ByteString.copyFrom(chunk, 0, size)).build() emit(FileUploadRequest.newBuilder().setContent(fileChunk).build()) } }
A modern programming language that makes developers happier.