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

...8import 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    }266    @Test267    fun rxString() {268        mock.chain(269            request = mock.request().withPath("/user-agent"),270            response = mock.reflect()271        )272        val data = Fuel.get(mock.path("user-agent"))273            .rxString()274            .test()275            .apply { awaitTerminalEvent() }276            .assertNoErrors()277            .assertValueCount(1)278            .assertComplete()279            .values()[0]280        assertThat(data, notNullValue())281        assertThat(data as Result.Success, isA(Result.Success::class.java))282        val (value, error) = data283        assertThat(value, notNullValue())284        assertThat(error, nullValue())285    }286    @Test287    fun rxStringPair() {288        mock.chain(289            request = mock.request().withPath("/user-agent"),290            response = mock.reflect()291        )292        val data = Fuel.get(mock.path("user-agent"))293            .rxStringPair()294            .test()295            .apply { awaitTerminalEvent() }296            .assertNoErrors()297            .assertValueCount(1)298            .assertComplete()299            .values()[0]300        assertThat(data, notNullValue())301        assertThat(data.first.statusCode, equalTo(HttpURLConnection.HTTP_OK))302        assertThat(data.second as Result.Success, isA(Result.Success::class.java))303        val (value, error) = data.second304        assertThat(value, notNullValue())305        assertThat(error, nullValue())306    }307    @Test308    fun rxStringTriple() {309        mock.chain(310                request = mock.request().withPath("/user-agent"),311                response = mock.reflect()312        )313        val data = Fuel.get(mock.path("user-agent"))314                .rxStringTriple()315                .test()316                .apply { awaitTerminalEvent() }317                .assertNoErrors()318                .assertValueCount(1)319                .assertComplete()320                .values()[0]321        assertThat(data, notNullValue())322        assertThat(data.first, notNullValue())323        assertThat(data.second.statusCode, equalTo(HttpURLConnection.HTTP_OK))324        assertThat(data.third as Result.Success, isA(Result.Success::class.java))325        val (value, error) = data.third326        assertThat(value, notNullValue())327        assertThat(error, nullValue())328    }329    @Test330    fun rxStringWithError() {331        mock.chain(332            request = mock.request().withPath("/error"),333            response = mock.response().withStatusCode(HttpURLConnection.HTTP_NOT_FOUND)334        )335        val data = Fuel.get(mock.path("error"))336            .rxString()337            .test()338            .apply { awaitTerminalEvent() }339            .assertNoErrors()340            .assertValueCount(1)341            .assertComplete()342            .values()[0]343        assertThat(data as Result.Failure, isA(Result.Failure::class.java))344        val (value, error) = data345        assertThat(value, nullValue())346        assertThat(error, notNullValue())347        assertThat(error?.exception?.message, containsString("404 Not Found"))348    }349    // Model350    data class HttpBinUserAgentModel(var userAgent: String = "")351    // Deserializer352    class HttpBinUserAgentModelDeserializer : ResponseDeserializable<HttpBinUserAgentModel> {353        override fun deserialize(content: String): HttpBinUserAgentModel? = HttpBinUserAgentModel(content)354    }355    class HttpBinMalformedDeserializer : ResponseDeserializable<HttpBinUserAgentModel> {356        override fun deserialize(inputStream: InputStream): HttpBinUserAgentModel? = throw IllegalStateException("Malformed data")357    }358    @Test359    fun rxResponseObjectPair() {360        mock.chain(361            request = mock.request().withPath("/user-agent"),362            response = mock.reflect()363        )364        val (response, result) = Fuel.get(mock.path("user-agent"))365            .rxResponseObjectPair(HttpBinUserAgentModelDeserializer())366            .test()367            .apply { awaitTerminalEvent() }368            .assertNoErrors()369            .assertValueCount(1)370            .assertComplete()371            .values()372            .first()373        assertThat(response, notNullValue())374        assertThat(result, notNullValue())375        assertThat(result, isA(HttpBinUserAgentModel::class.java))376    }377    @Test378    fun rxResponseObjectPairWithError() {379        mock.chain(380            request = mock.request().withPath("/user-agent"),381            response = mock.response().withStatusCode(HttpURLConnection.HTTP_NOT_FOUND)382        )383        val single = Fuel.get(mock.path("user-agent"))384            .rxResponseObjectPair(HttpBinUserAgentModelDeserializer())385            .test()386            .apply { awaitTerminalEvent() }387            .assertError(FuelError::class.java)388            .assertNoValues()389        val error = single.errors().firstOrNull()390        val (response, value) = single.values().firstOrNull() ?: Pair(null, null)391        assertThat("Expected error, actual response $response", response, nullValue())392        assertThat("Expected error, actual value $value", value, nullValue())393        assertThat(error, notNullValue())394    }395    @Test396    fun rxResponseObjectPairWithMalformed() {397        mock.chain(398            request = mock.request().withPath("/user-agent"),399            response = mock.reflect()400        )401        val single = Fuel.get(mock.path("user-agent"))402            .rxResponseObjectPair(HttpBinMalformedDeserializer())403            .test()404            .apply { awaitTerminalEvent() }405            .assertError(FuelError::class.java)406            .assertNoValues()407        val error = single.errors().firstOrNull()408        val (response, value) = single.values().firstOrNull() ?: Pair(null, null)409        assertThat("Expected error, actual response $response", response, nullValue())410        assertThat("Expected error, actual value $value", value, nullValue())411        val fuelError = error as? FuelError412        assertThat(fuelError, isA(FuelError::class.java))413        assertThat(fuelError!!.exception as IllegalStateException, isA(IllegalStateException::class.java))414        assertThat(fuelError.exception.message, isEqualTo("Malformed data"))415    }416    @Test...

1public final MockWebServer server = new MockWebServer();2public void setUp() {3    server.setDispatcher(new Dispatcher() {4        public MockResponse dispatch(RecordedRequest request) throws InterruptedException {5            return new MockResponse().setResponseCode(200);6        }7    });8}9public void rxResponseTest() throws Exception {10    final String url = server.url("/").toString();11    final Observable<Response> responseObservable = rxResponse(Method.GET, url);12    responseObservable.test().assertValue(response -> response.statusCode == 200);13}14public final MockWebServer server = new MockWebServer();15public void setUp() {16    server.setDispatcher(new Dispatcher() {17        public MockResponse dispatch(RecordedRequest request) throws InterruptedException {18            return new MockResponse().setResponseCode(200);19        }20    });21}22public void rxResponseTest() throws Exception {23    final String url = server.url("/").toString();24    final Observable<Response> responseObservable = rxResponse(Method.GET, url);25    responseObservable.test().assertValue(response -> response.statusCode == 200);26}27public final MockWebServer server = new MockWebServer();28public void setUp() {29    server.setDispatcher(new Dispatcher() {30        public MockResponse dispatch(RecordedRequest request) throws InterruptedException {31            return new MockResponse().setResponseCode(200);32        }33    });34}35public void rxResponseTest() throws Exception {36    final String url = server.url("/").toString();37    final Observable<Response> responseObservable = rxResponse(Method.GET, url);38    responseObservable.test().assertValue(response -> response.statusCode == 200);39}40public final MockWebServer server = new MockWebServer();41public void setUp() {42    server.setDispatcher(new Dispatcher() {43        public MockResponse dispatch(RecordedRequest request) throws InterruptedException {44            return new MockResponse().setResponseCode(200);45        }46    });47}48public void rxResponseTest() throws Exception

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

1fun rxResponse() {2    val (data, error) = result3    println(request)4    println(response)5    println(data)6}7fun rxFuel() {8    val (data, error) = result9    println(request)10    println(response)11    println(data)12}13fun rxString() {14    val (data, error) = result15    println(request)16    println(response)17    println(data)18}19fun rxJson() {20    val (data, error) = result21    println(request)22    println(response)23    println(data)24}25fun rxResponseObject() {26    val (data, error) = result27    println(request)28    println(response)29    println(data)30}31fun rxResponseObjectWithParameter() {

1val (request, response, result) = Fuel.get("get").rxResponse().toBlocking().single()2val (request, response, result) = Fuel.get("get").rxResponseObject().toBlocking().single()3val (request, response, result) = Fuel.get("get").rxResponseString().toBlocking().single()4val (request, response, result) = Fuel.get("get").rxResponseString().toBlocking().single()5val (request, response, result) = Fuel.get("get").rxResponseString().toBlocking().single()6val (request, response, result) = Fuel.get("get").rxResponseString().toBlocking().single()7val (request, response, result) = Fuel.get("get").rxResponseString().toBlocking().single()8val (