How to use makingRequestsAddingRequestBodyFromLazySource method of com.github.kittinunf.fuel.ReadmeIntegrityTest class

...128            }129            .join()130    }131    @Test132    fun makingRequestsAddingRequestBodyFromLazySource() {133        val contents = "source-string-from-string"134        val produceStream = { ByteArrayInputStream(contents.toByteArray()) }135        reflectedRequest(Method.POST, "post")136            .header(Headers.CONTENT_TYPE, "text/plain")137            .body(produceStream)138            .also { println(it) }139            .responseObject(MockReflected.Deserializer()) { result ->140                val (data, error) = result141                assertThat("Expected data, actual error $error", data, notNullValue())142                assertThat("Expected body to be set", data!!.body?.string, notNullValue())143                assertThat(data.body!!.string, equalTo(contents))144            }145            .join()146    }...

1    }2    fun makingRequestsAddingRequestBodyFromSource() {3    }4    fun makingRequestsAddingRequestBodyFromStream() {5    }6    fun makingRequestsAddingRequestBodyFromStreamWithBufferSize() {7    }8    fun makingRequestsAddingRequestBodyFromStreamWithBufferSizeAndOffset() {9    }10    fun makingRequestsAddingRequestBodyFromStreamWithBufferSizeAndOffsetAndLength() {11    }12    fun makingRequestsAddingRequestBodyFromStreamWithBufferSizeAndOffsetAndLengthAndClose() {13    }14    fun makingRequestsAddingRequestBodyFromStreamWithBufferSizeAndOffsetAndLengthAndCloseAndProgress() {15    }16    fun makingRequestsAddingRequestBodyFromStreamWithBufferSizeAndOffsetAndLengthAndProgress() {17    }18    fun makingRequestsAddingRequestBodyFromStreamWithBufferSizeAndProgress() {

1fun `makingRequestsAddingRequestBodyFromLazySource`() {2            .httpPost()3            .body { request, url ->4                val stream = ByteArrayInputStream("Hello, World!".toByteArray())5            }6            .responseString()7    assertThat(request, notNullValue())8    assertThat(response, notNullValue())9    assertThat(result, notNullValue())10}11fun `makingRequestsAddingRequestBodyFromSource`() {12            .httpPost()13            .body { request, url ->14                val stream = ByteArrayInputStream("Hello, World!".toByteArray())15            }16            .responseString()17    assertThat(request, notNullValue())18    assertThat(response, notNullValue())19    assertThat(result, notNullValue())20}21fun `makingRequestsAddingRequestBodyFromSourceWithLength`() {22            .httpPost()23            .body { request, url ->24                val stream = ByteArrayInputStream("Hello, World!".toByteArray())25            }26            .responseString()27    assertThat(request, notNullValue())28    assertThat(response, notNullValue())29    assertThat(result, notNullValue())30}31fun `makingRequestsAddingRequestBodyFromSourceWithLengthAndContentType`() {32            .httpPost()33            .body { request, url ->34                val stream = ByteArrayInputStream("Hello, World!".toByteArray())35            }36            .responseString()37    assertThat(request, notNullValue())38    assertThat(response, notNullValue())39    assertThat(result, notNullValue())40}

1fun makingRequestsAddingRequestBodyFromLazySource() {2    val data = "Hello World!".toByteArray()3    val source = { ByteArrayInputStream(data) }4        .source { _, _ -> source() }5        .responseString()6    assertEquals(data.size, request.contentLength)7    assertEquals(data.size, request.headers["Content-Length"]?.toLong())8    assertEquals(data.size, request.headers["Content-Length"]?.toLong())9    assertEquals("Hello World!", result.get())10}11fun makingRequestsAddingRequestBodyFromLazySource() {12    val data = "Hello World!".toByteArray()13    val source = { ByteArrayInputStream(data) }14        .source { _, _ -> source() }15        .responseString()16    assertEquals(data.size, request.contentLength)17    assertEquals(data.size, request.headers["Content-Length"]?.toLong())18    assertEquals(data.size, request.headers["Content-Length"]?.toLong())19    assertEquals("Hello World!", result.get())20}21fun makingRequestsAddingRequestBodyFromLazySource() {22    val data = "Hello World!".toByteArray()23    val source = { ByteArrayInputStream(data) }24        .source { _, _ -> source() }25        .responseString()26    assertEquals(data.size, request.contentLength)27    assertEquals(data.size, request.headers["Content-Length"]?.toLong())28    assertEquals(data.size, request.headers["Content-Length"]?.toLong())29    assertEquals("Hello World!", result.get())30}31fun makingRequestsAddingRequestBodyFromLazySource() {32    val data = "Hello World!".toByteArray()33    val source = { ByteArrayInputStream(data) }34        .source { _, _ -> source() }

1fun makingRequestsAddingRequestBodyFromLazySource() {2    val parameters = listOf("foo" to "bar")3    val data = "Hello World".byteInputStream()4    val source = { data }5    val request = Fuel.upload("/post")6            .source { request, url ->7            }8            .body(parameters)9            .responseString()10    assertEquals(request.second.statusCode, 200)11    assertEquals(request.third.component1(), "Hello World")12}13fun makingRequestsAddingRequestBodyFromSource() {14    val parameters = listOf("foo" to "bar")15    val data = "Hello World".byteInputStream()16    val source = { data }17    val request = Fuel.upload("/post")18            .source { request, url ->19            }20            .body(parameters)21            .responseString()22    assertEquals(request.second.statusCode, 200)23    assertEquals(request.third.component1(), "Hello World")24}25fun makingRequestsAddingRequestBodyFromSourceWithProgress() {26    val parameters = listOf("foo" to "bar")27    val data = "Hello World".byteInputStream()28    val source = { data }29    val request = Fuel.upload("/post")30            .source { request, url ->31            }32            .body(parameters)33            .responseString()34    assertEquals(request.second.statusCode, 200)35    assertEquals(request.third.component1(), "Hello World")36}37fun makingRequestsAddingRequestBodyFromSourceWithProgressAndCallback() {38    val parameters = listOf("foo" to "bar")39    val data = "Hello World".byteInputStream()40    val source = { data }41    val request = Fuel.upload("/post")42            .source { request, url ->43            }44            .body(parameters)45            .responseString()46    assertEquals(request.second.statusCode, 200)47    assertEquals(request.third.component1(), "Hello World")48}

1val  lazySource  = {  ("lazy source"  to  "lazy source" )  }2makingRequestsAddingRequestBodyFromLazySource(lazySource)3val  lazySource  = {  ("lazy source"  to  "lazy source" )  }4makingRequestsAddingRequestBodyFromLazySource(lazySource)5val  lazySource  = {  ("lazy source"  to  "lazy source" )  }6makingRequestsAddingRequestBodyFromLazySource(lazySource)7val  lazySource  = {  ("lazy source"  to  "lazy source" )  }8makingRequestsAddingRequestBodyFromLazySource(lazySource)9val  lazySource  = {  ("lazy source"  to  "lazy source" )  }10makingRequestsAddingRequestBodyFromLazySource(lazySource)11val  lazySource  = {  ("lazy source"  to  "lazy source" )  }12makingRequestsAddingRequestBodyFromLazySource(lazySource)13val  lazySource  = {  ("lazy source"  to  "lazy source" )  }14makingRequestsAddingRequestBodyFromLazySource(lazySource)15val  lazySource  = {  ("lazy source"  to  "lazy source" )  }16makingRequestsAddingRequestBodyFromLazySource(lazySource)