From 238a4df95bac3335d9a08eb38038242367ac38f9 Mon Sep 17 00:00:00 2001 From: Cedric Beust Date: Fri, 11 Mar 2016 22:04:36 +0400 Subject: [PATCH] Use the inputStream. --- .../kobalt/misc/CountingFileRequestBody.kt | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/misc/CountingFileRequestBody.kt b/modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/misc/CountingFileRequestBody.kt index fd90564c..72e45a7c 100644 --- a/modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/misc/CountingFileRequestBody.kt +++ b/modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/misc/CountingFileRequestBody.kt @@ -19,15 +19,17 @@ class CountingFileRequestBody(val file: File, val contentType: String, override fun contentType() = MediaType.parse(contentType) override fun writeTo(sink: BufferedSink) { - Okio.source(file).use { source -> - var total = 0L - var read: Long = source.read(sink.buffer(), SEGMENT_SIZE) + file.inputStream().use { fis -> + Okio.source(fis).use { source -> + var total = 0L + var read: Long = source.read(sink.buffer(), SEGMENT_SIZE) - while (read != -1L) { - total += read - sink.flush(); - listenerCallback(total) - read = source.read(sink.buffer(), SEGMENT_SIZE) + while (read != -1L) { + total += read + sink.flush(); + listenerCallback(total) + read = source.read(sink.buffer(), SEGMENT_SIZE) + } } } }