How to use rxBytesTriple method of com.github.kittinunf.fuel.RxFuelTest class

...5import com.github.kittinunf.fuel.core.Response6import com.github.kittinunf.fuel.core.ResponseDeserializable7import com.github.kittinunf.fuel.rx.rxBytes8import com.github.kittinunf.fuel.rx.rxBytesPair9import com.github.kittinunf.fuel.rx.rxBytesTriple10import com.github.kittinunf.fuel.rx.rxCompletable11import com.github.kittinunf.fuel.rx.rxObject12import com.github.kittinunf.fuel.rx.rxResponse13import com.github.kittinunf.fuel.rx.rxResponseObject14import com.github.kittinunf.fuel.rx.rxResponseObjectPair15import com.github.kittinunf.fuel.rx.rxResponseObjectTriple16import com.github.kittinunf.fuel.rx.rxResponsePair17import com.github.kittinunf.fuel.rx.rxResponseString18import com.github.kittinunf.fuel.rx.rxResponseStringPair19import com.github.kittinunf.fuel.rx.rxResponseStringTriple20import com.github.kittinunf.fuel.rx.rxResponseTriple21import com.github.kittinunf.fuel.rx.rxString22import com.github.kittinunf.fuel.rx.rxStringPair23import com.github.kittinunf.fuel.rx.rxStringTriple24import com.github.kittinunf.fuel.test.MockHttpTestCase25import com.github.kittinunf.result.Result26import org.hamcrest.CoreMatchers.containsString27import org.hamcrest.CoreMatchers.equalTo28import org.hamcrest.CoreMatchers.notNullValue29import org.hamcrest.CoreMatchers.nullValue30import org.hamcrest.core.Is.isA31import org.junit.Assert.assertThat32import org.junit.Test33import java.io.InputStream34import java.net.HttpURLConnection35import org.hamcrest.CoreMatchers.`is` as isEqualTo36class RxFuelTest : MockHttpTestCase() {37    @Test38    fun rxResponse() {39        mock.chain(40            request = mock.request().withPath("/user-agent"),41            response = mock.reflect()42        )43        val data = Fuel.get(mock.path("user-agent"))44            .rxResponse()45            .test()46            .apply { awaitTerminalEvent() }47            .assertNoErrors()48            .assertValueCount(1)49            .assertComplete()50            .values()[0]51        assertThat(data, notNullValue())52    }53    @Test54    fun rxResponsePair() {55        mock.chain(56            request = mock.request().withPath("/user-agent"),57            response = mock.reflect()58        )59        val (response, data) = Fuel.get(mock.path("user-agent"))60            .rxResponsePair()61            .test()62            .apply { awaitTerminalEvent() }63            .assertNoErrors()64            .assertValueCount(1)65            .assertComplete()66            .values()[0]67        assertThat(response, notNullValue())68        assertThat(response.statusCode, equalTo(HttpURLConnection.HTTP_OK))69        assertThat(data, notNullValue())70    }71    @Test72    fun rxResponseTriple() {73        mock.chain(74            request = mock.request().withPath("/user-agent"),75            response = mock.reflect()76        )77        val (request, response, data) = Fuel.get(mock.path("user-agent"))78            .rxResponseTriple()79            .test()80            .apply { awaitTerminalEvent() }81            .assertNoErrors()82            .assertValueCount(1)83            .assertComplete()84            .values()[0]85        assertThat(request, notNullValue())86        assertThat(request.method, equalTo(GET))87        assertThat(response, notNullValue())88        assertThat(response.statusCode, equalTo(HttpURLConnection.HTTP_OK))89        assertThat(data, notNullValue())90    }91    @Test92    fun rxResponseString() {93        mock.chain(94                request = mock.request().withPath("/user-agent"),95                response = mock.reflect()96        )97        val data = Fuel.get(mock.path("user-agent"))98                .rxResponseString()99                .test()100                .apply { awaitTerminalEvent() }101                .assertNoErrors()102                .assertValueCount(1)103                .assertComplete()104                .values()[0]105        assertThat(data, notNullValue())106    }107    @Test108    fun rxResponseStringPair() {109        mock.chain(110            request = mock.request().withPath("/user-agent"),111            response = mock.reflect()112        )113        val (response, data) = Fuel.get(mock.path("user-agent"))114            .rxResponseStringPair()115            .test()116            .apply { awaitTerminalEvent() }117            .assertNoErrors()118            .assertValueCount(1)119            .assertComplete()120            .values()[0]121        assertThat(response, notNullValue())122        assertThat(response.statusCode, equalTo(HttpURLConnection.HTTP_OK))123        assertThat(data, notNullValue())124    }125    @Test126    fun rxResponseStringTriple() {127        mock.chain(128            request = mock.request().withPath("/user-agent"),129            response = mock.reflect()130        )131        val (request, response, data) = Fuel.get(mock.path("user-agent"))132            .rxResponseStringTriple()133            .test()134            .apply { awaitTerminalEvent() }135            .assertNoErrors()136            .assertValueCount(1)137            .assertComplete()138            .values()[0]139        assertThat(response, notNullValue())140        assertThat(request, notNullValue())141        assertThat(response.statusCode, equalTo(HttpURLConnection.HTTP_OK))142        assertThat(data, notNullValue())143    }144    data class Foo(val string: String)145    @Test146    fun rxResponseObject() {147        mock.chain(148                request = mock.request().withPath("/user-agent"),149                response = mock.reflect()150        )151        val data = Fuel.get(mock.path("user-agent"))152                .rxResponseObject(object : Deserializable<Foo> {153                    override fun deserialize(response: Response): Foo = Foo("user-agent")154                })155                .test()156                .apply { awaitTerminalEvent() }157                .assertNoErrors()158                .assertValueCount(1)159                .assertComplete()160                .values()[0]161        assertThat(data, notNullValue())162        assertThat(data.string, equalTo("user-agent"))163    }164    @Test165    fun rxResponseObjectTriple() {166        mock.chain(167            request = mock.request().withPath("/user-agent"),168            response = mock.reflect()169        )170        val (request, response, data) = Fuel.get(mock.path("user-agent"))171            .rxResponseObjectTriple(object : Deserializable<Foo> {172                override fun deserialize(response: Response): Foo = Foo("xxx")173            })174            .test()175            .apply { awaitTerminalEvent() }176            .assertNoErrors()177            .assertValueCount(1)178            .assertComplete()179            .values()[0]180        assertThat(response, notNullValue())181        assertThat(request, notNullValue())182        assertThat(response.statusCode, equalTo(HttpURLConnection.HTTP_OK))183        assertThat(data, notNullValue())184        assertThat(data.string, equalTo("xxx"))185    }186    @Test187    fun rxResponseObjectTripleWithError() {188        mock.chain(189            request = mock.request().withPath("/user-agent"),190            response = mock.reflect()191        )192        val err = Fuel.get(mock.path("user-agent"))193                .rxResponseObjectTriple(object : Deserializable<Foo> {194                    override fun deserialize(response: Response): Foo = throw error("error")195                })196                .test()197                .apply { awaitTerminalEvent() }198                .assertError(FuelError::class.java)199                .assertNoValues()200                .errors()[0]201        assertThat(err, notNullValue())202    }203    @Test204    fun rxBytes() {205        mock.chain(206            request = mock.request().withPath("/bytes"),207            response = mock.response().withStatusCode(HttpURLConnection.HTTP_OK).withBody(ByteArray(555) { 0 })208        )209        val data = Fuel.get(mock.path("bytes"))210            .rxBytes()211            .test()212            .apply { awaitTerminalEvent() }213            .assertNoErrors()214            .assertValueCount(1)215            .assertComplete()216            .values()[0]217        assertThat(data, notNullValue())218        assertThat(data as Result.Success, isA(Result.Success::class.java))219        val (value, error) = data220        assertThat(value, notNullValue())221        assertThat(error, nullValue())222    }223    @Test224    fun rxBytesPair() {225        mock.chain(226            request = mock.request().withPath("/bytes"),227            response = mock.response().withStatusCode(HttpURLConnection.HTTP_OK).withBody(ByteArray(555) { 0 })228        )229        val (resp, result) = Fuel.get(mock.path("bytes"))230            .rxBytesPair()231            .test()232            .apply { awaitTerminalEvent() }233            .assertNoErrors()234            .assertValueCount(1)235            .assertComplete()236            .values()[0]237        assertThat(resp, notNullValue())238        assertThat(resp.statusCode, equalTo(HttpURLConnection.HTTP_OK))239        assertThat(result as Result.Success, isA(Result.Success::class.java))240        val (value, error) = result241        assertThat(value, notNullValue())242        assertThat(error, nullValue())243    }244    @Test245    fun rxBytesTriple() {246        mock.chain(247                request = mock.request().withPath("/bytes"),248                response = mock.response().withStatusCode(HttpURLConnection.HTTP_OK).withBody(ByteArray(555) { 0 })249        )250        val (req, resp, result) = Fuel.get(mock.path("bytes"))251                .rxBytesTriple()252                .test()253                .apply { awaitTerminalEvent() }254                .assertNoErrors()255                .assertValueCount(1)256                .assertComplete()257                .values()[0]258        assertThat(req, notNullValue())259        assertThat(resp, notNullValue())260        assertThat(resp.statusCode, equalTo(HttpURLConnection.HTTP_OK))261        assertThat(result as Result.Success, isA(Result.Success::class.java))262        val (value, error) = result263        assertThat(value, notNullValue())264        assertThat(error, nullValue())265    }...

1val (request, response, result) = rxBytesTriple().toBlocking().single()2val (request, response, result) = rxBytes().toBlocking().single()3val (request, response, result) = rxStringTriple().toBlocking().single()4val (request, response, result) = rxString().toBlocking().single()5val (request, response, result) = rxResponseTriple().toBlocking().single()6val (request, response, result) = rxResponse().toBlocking().single()7val (request, response, result) = rxJsonTriple().toBlocking().single()8val (request, response, result) = rxJson().toBlocking().single()9val (request, response, result) = rxXmlTriple().toBlocking().single()10val (request, response, result) = rxXml().toBlocking().single()11val (request, response, result) = rxDownloadTriple().toBlocking().single()12val (request, response, result) = rxDownload().toBlocking().single()13val (request, response,

1val test = com.github.kittinunf.fuel.RxFuelTest()2test.rxBytesTriple()3val test = com.github.kittinunf.fuel.RxFuelTest()4test.rxBytesTriple()5val test = com.github.kittinunf.fuel.RxFuelTest()6test.rxBytesTriple()7val test = com.github.kittinunf.fuel.RxFuelTest()8test.rxBytesTriple()9val test = com.github.kittinunf.fuel.RxFuelTest()10test.rxBytesTriple()11val test = com.github.kittinunf.fuel.RxFuelTest()12test.rxBytesTriple()13val test = com.github.kittinunf.fuel.RxFuelTest()14test.rxBytesTriple()15val test = com.github.kittinunf.fuel.RxFuelTest()16test.rxBytesTriple()17val test = com.github.kittinunf.fuel.RxFuelTest()18test.rxBytesTriple()19val test = com.github.kittinunf.fuel.RxFuelTest()20test.rxBytesTriple()21val test = com.github.kittinunf.fuel.RxFuelTest()22test.rxBytesTriple()

1    fun rxBytesTriple() {2        val (request2, response2, result2) = request.rx_bytes().toBlocking().single()3        assertThat(request2, notNullValue())4        assertThat(response2, notNullValue())5        assertThat(result2, notNullValue())6        assertThat(result2.component1(), notNullValue())7    }8    fun rxResponse() {9        val (request2, response2, result2) = request.rx_response().toBlocking().single()10        assertThat(request2, notNullValue())11        assertThat(response2, notNullValue())12        assertThat(result2, notNullValue())13        assertThat(result2.component1(), notNullValue())14    }15    fun rxResponseTriple() {16        val (request2, response2, result2) = request.rx_response().toBlocking().single()17        assertThat(request2, notNullValue())18        assertThat(response2, notNullValue())19        assertThat(result2, notNullValue())20        assertThat(result2.component1(), notNullValue())21    }22    fun rxResponseObject() {23        val (request2, response2, result2) = request.rx_response_object<HttpBinUserAgentModel>().toBlocking().single()24        assertThat(request2, notNullValue())25        assertThat(response2, notNullValue())26        assertThat(result2, notNullValue())27        assertThat(result2.component1(), notNullValue())28    }29    fun rxResponseObjectTriple() {30        val (request2, response2, result2) = request