How to use dataStream method of com.github.kittinunf.fuel.toolbox.HttpClient class

...170        if (transferEncoding.any { encoding -> encoding.isNotBlank() && encoding != "identity" }) {171            headers.remove(Headers.CONTENT_LENGTH)172            contentLength = -1173        }174        val contentStream = dataStream(request, connection)?.decode(transferEncoding) ?: ByteArrayInputStream(ByteArray(0))175        val inputStream = if (shouldDecode && contentEncoding != null) contentStream.decode(contentEncoding) else contentStream176        val cancellationConnection = WeakReference<HttpURLConnection>(connection)177        val progressStream = ProgressInputStream(178            inputStream, onProgress = { readBytes ->179                request.executionOptions.responseProgress(readBytes, contentLength ?: readBytes)180                ensureRequestActive(request, cancellationConnection.get())181            }182        )183        // The input and output streams returned by connection are not buffered. In order to give consistent progress184        // reporting, by means of flushing, the input stream here is buffered.185        return Response(186            url = request.url,187            headers = headers,188            contentLength = contentLength ?: -1,189            statusCode = connection.responseCode,190            responseMessage = connection.responseMessage.orEmpty(),191            body = DefaultBody.from(192                { progressStream.buffered(FuelManager.progressBufferSize) },193                { contentLength ?: -1 }194            )195        )196    }197    private fun dataStream(request: Request, connection: HttpURLConnection): InputStream? = try {198        hook.interpretResponseStream(request, connection.inputStream)?.buffered()199    } catch (_: IOException) {200        hook.interpretResponseStream(request, connection.errorStream)?.buffered()201    }202    private fun establishConnection(request: Request): HttpURLConnection {203        val url = request.url204        val connection = proxy?.let { url.openConnection(it) } ?: url.openConnection()205        return connection as HttpURLConnection206    }207    private fun setBodyIfDoOutput(connection: HttpURLConnection, request: Request) {208        val body = request.body209        if (!connection.doOutput) {210            return211        }...

...72                headers = connection.headerFields.filterKeys { it != null },73                contentLength = connection.contentLength.toLong(),74                statusCode = connection.responseCode,75                responseMessage = connection.responseMessage.orEmpty(),76                dataStream = try {77                    val stream = connection.errorStream ?: connection.inputStream78                    if (contentEncoding.compareTo("gzip", true) == 0) GZIPInputStream(stream) else stream79                } catch (exception: IOException) {80                    connection.errorStream ?: connection.inputStream?.close()81                    ByteArrayInputStream(ByteArray(0))82                }83            )84        } catch (exception: Exception) {85            throw FuelError(exception, ByteArray(0), Response(request.url))86        } finally {87            // As per Android documentation, a connection that is not explicitly disconnected88            // will be pooled and reused!  So, don't close it as we need inputStream later!89            // connection.disconnect()90        }...

1data class User(val userId: Int, val id: Int, val title: String, val body: String)2fun main() {3        .httpGet()4        .responseString()5    println(request)6    println(response)7    println(result)8        .httpGet()9        .responseString()10    println(request1)11    println(response1)12    println(result1)13        .httpGet()14        .responseString()15    println(request2)16    println(response2)17    println(result2)18    val client = HttpClient()19    val response3 = client.request(request3)20    println(request3)21    println(response3)22    println(result3)23    val response4 = client.request(request4)24    println(request4)25    println(response4)26    println(result4)27    val response5 = client.request(request5)28    println(request5)29    println(response5)30    println(result5)31}

1dataStream { request, response, stream ->2}3download { request, response, stream ->4}5upload { request, response, stream ->6}7upload { request, response, stream ->8}9upload { request, response, stream ->10}11upload { request, response, stream ->12}13upload { request, response, stream ->14}15upload { request, response, stream ->16}17upload { request, response, stream ->18}19upload { request, response, stream ->20}21upload { request, response, stream ->22}23upload { request, response, stream ->24}25upload { request, response, stream ->26}27upload { request

1        .header("Content-Type" to "application/json")2        .body("{\"hello\":\"world\"}")3        .responseStream { request, response, result ->4            val (bytes, error) = result5            if (bytes != null) {6                println(bytes)7            }8        }9    println(request)10    println(response)11    println(result)12}13        .header("Content-Type" to "application/json")14        .body("{\"hello\":\"world\"}")15        .response { request, response, result ->16            val (bytes, error) = result17            if (bytes != null) {18                println(bytes)19            }20        }21    println(request)22    println(response)23    println(result)

1public void getResponseFromServer() {2FuelManager.instance.baseHeaders = mapOf("Accept" to "application/json")3FuelManager.instance.baseParams = listOf("key" to "value")4FuelManager.instance.baseHeaders = mapOf("Accept" to "application/json")5FuelManager.instance.baseParams = listOf("key" to "value")6FuelManager.instance.baseHeaders = mapOf("Accept" to "application/json")7FuelManager.instance.baseParams = listOf("key" to "value")8FuelManager.instance.baseHeaders = mapOf("Accept" to "application/json")9FuelManager.instance.baseParams = listOf("key" to "value")10FuelManager.instance.baseHeaders = mapOf("Accept" to "application/json")11FuelManager.instance.baseParams = listOf("key" to "value")12FuelManager.instance.baseHeaders = mapOf("Accept" to "application/json")13FuelManager.instance.baseParams = listOf("key" to "value")14FuelManager.instance.baseHeaders = mapOf("Accept" to "application/json")15FuelManager.instance.baseParams = listOf("key" to "value")16FuelManager.instance.baseHeaders = mapOf("Accept" to "application/json")17FuelManager.instance.baseParams = listOf("key" to "value")18FuelManager.instance.baseHeaders = mapOf("Accept" to "application/json")19FuelManager.instance.baseParams = listOf("key" to "value")20FuelManager.instance.baseHeaders = mapOf("Accept" to "application/json")21FuelManager.instance.baseParams = listOf("key" to "value")22FuelManager.instance.baseHeaders = mapOf("Accept" to "application/json")23FuelManager.instance.baseParams = listOf("key" to "value")

1val (inputStream, error) = FuelManager.instance.dataStream(url).third2val (inputStream, error) = FuelManager.instance.dataStream(url).third3val (inputStream, error) = FuelManager.instance.dataStream(url).third4val (inputStream, error) = FuelManager.instance.dataStream(url).third5val (inputStream, error) = FuelManager.instance.dataStream(url).third6val (inputStream, error) = FuelManager.instance.dataStream(url).third7val (inputStream, error) = FuelManager.instance.dataStream(url).third8val (inputStream, error) = FuelManager.instance.dataStream(url).third9val (inputStream, error) = FuelManager.instance.dataStream(url).third10val (inputStream, error) = FuelManager.instance.dataStream(url).third

1val inputStream = HttpClient().dataStream(request)2val response = inputStream.bufferedReader().use(BufferedReader::readText)3println(response)4}5}6{"args":{},"headers":{"Accept":"*/*","Accept-Encoding":"gzip, deflate, br","Accept-Language":"en-US,en;q=0.9","Connection":"keep-alive","Host":"httpbin.org","User-Agent":"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/69.0.3497.100 Safari/537.36"},"origin":"