How to use Request.monoResponse method of com.github.kittinunf.fuel.reactor.Reactor class

Best Fuel code snippet using com.github.kittinunf.fuel.reactor.Reactor.Request.monoResponse

ReactorTest.kt

Source:ReactorTest.kt Github

copy

Full Screen

1package com.github.kittinunf.fuel.reactor2import com.fasterxml.jackson.databind.exc.InvalidFormatException3import com.fasterxml.jackson.module.kotlin.MissingKotlinParameterException4import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper5import com.fasterxml.jackson.module.kotlin.readValue6import com.github.kittinunf.fuel.Fuel7import com.github.kittinunf.fuel.core.FuelError8import com.github.kittinunf.fuel.core.Response9import com.github.kittinunf.fuel.core.ResponseDeserializable10import com.github.kittinunf.fuel.test.MockHttpTestCase11import com.github.kittinunf.result.Result12import org.hamcrest.CoreMatchers.equalTo13import org.hamcrest.MatcherAssert.assertThat14import org.junit.Assert.assertEquals15import org.junit.Assert.assertTrue16import org.junit.Test17import reactor.core.publisher.Mono18import reactor.core.publisher.onErrorResume19import reactor.test.test20import java.util.UUID21class ReactorTest : MockHttpTestCase() {22 @Test23 fun monoBytes() {24 mock.chain(25 request = mock.request().withPath("/bytes"),26 response = mock.response().withBody(ByteArray(10))27 )28 Fuel.get(mock.path("bytes")).monoBytes()29 .test()30 .assertNext { assertEquals(10, it.size) }31 .verifyComplete()32 }33 @Test34 fun monoString() {35 mock.chain(36 request = mock.request().withPath("/ip"),37 response = mock.response().withBody("127.0.0.1")38 )39 Fuel.get(mock.path("ip")).monoString()40 .test()41 .assertNext { assertEquals("127.0.0.1", it) }42 .verifyComplete()43 }44 @Test45 fun monoObject() {46 mock.chain(47 request = mock.request().withPath("/ip"),48 response = mock.response()49 .withBody(jacksonObjectMapper().writeValueAsString(Ip("127.0.0.1")))50 )51 Fuel.get(mock.path("ip")).monoObject(IpDeserializerSuccess)52 .map(Ip::origin)53 .test()54 .assertNext { assertEquals("127.0.0.1", it) }55 .verifyComplete()56 }57 @Test58 fun monoObjectWithInvalidFormat() {59 mock.chain(60 request = mock.request().withPath("/ip"),61 response = mock.response()62 .withBody(jacksonObjectMapper().writeValueAsString(Ip("127.0.0.1")))63 )64 Fuel.get(mock.path("ip")).monoObject(IpLongDeserializer)65 .map(IpLong::origin)66 .test()67 .expectErrorMatches { (it as FuelError).exception is InvalidFormatException }68 .verify()69 }70 @Test71 fun monoObjectWithMissingProperty() {72 mock.chain(73 request = mock.request().withPath("/ip"),74 response = mock.response()75 .withBody(jacksonObjectMapper().writeValueAsString(Ip("127.0.0.1")))76 )77 val errorMessage = Fuel.get(mock.path("ip")).monoObject(IpAddressDeserializer)78 .map(IpAddress::address)79 .onErrorResume(FuelError::class) {80 assertTrue(it.exception is MissingKotlinParameterException)81 Mono.just(it.message.orEmpty())82 }83 .block()!!84 assertTrue(errorMessage.contains("value failed for JSON property address due to missing"))85 }86 @Test87 fun monoResponse() {88 mock.chain(89 request = mock.request().withPath("/status"),90 response = mock.response().withStatusCode(404)91 )92 Fuel.get(mock.path("status")).monoResponse()93 .map(Response::statusCode)94 .test()95 .assertNext { assertEquals(it, 404) }96 .verifyComplete()97 }98 @Test99 fun monoResultBytes() {100 mock.chain(101 request = mock.request().withPath("/bytes"),102 response = mock.response().withBody(ByteArray(20))103 )104 Fuel.get(mock.path("bytes")).monoResultBytes()105 .map(Result<ByteArray, FuelError>::get)106 .test()107 .assertNext { assertEquals(20, it.size) }108 .verifyComplete()109 }110 @Test111 fun monoResultString() {112 val randomUuid = UUID.randomUUID().toString()113 mock.chain(114 request = mock.request().withPath("/uuid"),115 response = mock.response().withBody(randomUuid)116 )117 Fuel.get(mock.path("uuid")).monoResultString()118 .map(Result<String, FuelError>::get)119 .test()120 .assertNext { assertEquals(randomUuid, it) }121 .verifyComplete()122 }123 @Test124 fun monoResultObject() {125 mock.chain(126 request = mock.request().withPath("/ip"),127 response = mock.response()128 .withBody(jacksonObjectMapper().writeValueAsString(Ip("192.168.0.1")))129 )130 Fuel.get(mock.path("ip")).monoResultObject(IpDeserializerSuccess)131 .map(Result<Ip, FuelError>::get)132 .map(Ip::origin)133 .test()134 .assertNext { assertEquals("192.168.0.1", it) }135 .verifyComplete()136 }137 @Test138 fun monoResultObjectWithInvalidFormat() {139 mock.chain(140 request = mock.request().withPath("/ip"),141 response = mock.response()142 .withBody(jacksonObjectMapper().writeValueAsString(Ip("192.168.0.1")))143 )144 Fuel.get(mock.path("ip")).monoResultObject(IpLongDeserializer)145 .map(Result<IpLong, FuelError>::component2)146 .test()147 .assertNext { assertTrue(it?.exception is InvalidFormatException) }148 .verifyComplete()149 }150 @Test151 fun monoResultObjectWithMissingProperty() {152 mock.chain(153 request = mock.request().withPath("/ip"),154 response = mock.response()155 .withBody(jacksonObjectMapper().writeValueAsString(Ip("192.168.0.1")))156 )157 Fuel.get(mock.path("ip")).monoResultObject(IpAddressDeserializer)158 .map(Result<IpAddress, FuelError>::component2)159 .test()160 .assertNext { assertTrue(it?.exception is MissingKotlinParameterException) }161 .verifyComplete()162 }163 @Test164 fun monoCancellation() {165 mock.chain(166 request = mock.request().withPath("/bytes"),167 response = mock.response().withBody(ByteArray(10))168 )169 val running = Fuel.get(mock.path("bytes"))170 .monoBytes()171 .toProcessor()172 running.cancel()173 assertThat(running.isCancelled, equalTo(true))174 }175 @Test176 fun monoUnit() {177 mock.chain(178 request = mock.request().withPath("/ip"),179 response = mock.response().withBody("127.0.0.1")180 )181 Fuel.get(mock.path("ip")).monoUnit()182 .test()183 .assertNext { assertThat(it, equalTo(Unit)) }184 .verifyComplete()185 }186 private data class IpLong(val origin: Long)187 private object IpLongDeserializer : ResponseDeserializable<IpLong> {188 override fun deserialize(content: String) = jacksonObjectMapper().readValue<IpLong>(content)189 }190 private data class IpAddress(val address: String)191 private object IpAddressDeserializer : ResponseDeserializable<IpAddress> {192 override fun deserialize(content: String) = jacksonObjectMapper().readValue<IpAddress>(content)193 }194 private data class Ip(val origin: String)195 private object IpDeserializerSuccess : ResponseDeserializable<Ip> {196 override fun deserialize(content: String) = jacksonObjectMapper().readValue<Ip>(content)197 }198}...

Full Screen

Full Screen

OAuthApplication.kt

Source:OAuthApplication.kt Github

copy

Full Screen

1package gg.botlabs.oauth2import com.github.kittinunf.fuel.core.Request3import com.github.kittinunf.fuel.core.isSuccessful4import com.github.kittinunf.fuel.httpPost5import com.github.kittinunf.fuel.reactor.monoResponse6import com.github.kittinunf.fuel.reactor.monoUnit7import org.json.JSONObject8import reactor.core.publisher.Mono9import java.lang.IllegalStateException10import java.time.Instant11@Suppress("MemberVisibilityCanBePrivate", "unused")12class OAuthApplication(13 val tokenUrl: String,14 val clientId: String,15 val clientSecret: String,16 val redirectUri: String,17 val revocationUrl: String? = null18) {19 /** Exchanges the code for a new grant of type authorization_code */20 fun <T> exchangeCode(handler: GrantHandler<T>, code: String, scope: List<String>? = null): Mono<T> = tokenUrl.httpPost(21 listOfNotNull(22 "client_id" to clientId,23 "client_secret" to clientSecret,24 "grant_type" to "authorization_code",25 "code" to code,26 "redirect_uri" to redirectUri,27 scope?.let { "scope" to it.joinToString(" ") }28 )29 ).toGrantMono(handler, false)30 /** Attempts to refresh a grant */31 fun <T> refreshGrant(handler: RefreshHandler<T>, grant: TokenGrant): Mono<T> = refreshGrant(handler, grant.refreshToken)32 /** Attempts to refresh a grant */33 fun <T> refreshGrant(handler: RefreshHandler<T>, refreshToken: String): Mono<T> = tokenUrl.httpPost(34 listOfNotNull(35 "client_id" to clientId,36 "client_secret" to clientSecret,37 "grant_type" to "refresh_token",38 "refresh_token" to refreshToken,39 "redirect_uri" to redirectUri40 )41 ).toGrantMono(handler, true)42 fun refresh(refreshToken: String): Mono<TokenGrant> = tokenUrl.httpPost(43 listOfNotNull(44 "client_id" to clientId,45 "client_secret" to clientSecret,46 "grant_type" to "refresh_token",47 "refresh_token" to refreshToken,48 "redirect_uri" to redirectUri49 )50 ).toGrantMonoNoHandler()51 fun revoke(token: String): Mono<Unit> {52 if (revocationUrl == null) throw IllegalStateException("Revocation URL not provided")53 return revocationUrl.httpPost(54 listOf(55 "token" to token,56 "client_id" to clientId,57 "client_secret" to clientSecret58 )59 ).monoUnit()60 }61 /** Returns immediately if the bearer has not expired. Otherwise calls [refreshGrant] */62 fun <T> getFreshGrant(handler: RefreshHandler<T>, grant: TokenGrant, toleranceSeconds: Long = 300): Mono<T> {63 val expiry = grant.expires.minusSeconds(toleranceSeconds)64 if (Instant.now().isBefore(expiry)) return Mono.just(handler.onUnchanged()!!)65 return refreshGrant(handler, grant)66 }67 private fun <T> Request.toGrantMono(handler: GrantHandler<T>, isRefresh: Boolean): Mono<T> = header("Accept", "application/json")68 .monoResponse()69 .flatMap { res ->70 val bodyStr = res.data.decodeToString()71 val json: JSONObject72 try {73 json = JSONObject(bodyStr)74 } catch (e: Exception) {75 OAuthException.onInvalidJson(bodyStr)76 }77 if (json.optString("error") == "invalid_grant") {78 val refreshHandler = handler as RefreshHandler79 @Suppress("UNCHECKED_CAST") // Type cast safe as Mono<Void> returns empty80 return@flatMap refreshHandler.onInvalidGrant(res) as Mono<T>81 }82 if (!res.isSuccessful) OAuthException.onError(json)83 handler.handleTokenGrant(json.run {84 TokenGrant(85 getString("access_token"),86 getString("refresh_token"),87 optString("scope")?.split(' '),88 Instant.now().plusSeconds(getLong("expires_in"))89 )90 })91 }92 private fun Request.toGrantMonoNoHandler(): Mono<TokenGrant> = header("Accept", "application/json")93 .monoResponse()94 .map { res ->95 val bodyStr = res.data.decodeToString()96 val json: JSONObject97 try {98 json = JSONObject(bodyStr)99 } catch (e: Exception) {100 OAuthException.onInvalidJson(bodyStr)101 }102 if (!res.isSuccessful) OAuthException.onError(json)103 json.run {104 TokenGrant(105 getString("access_token"),106 getString("refresh_token"),107 optString("scope")?.split(' '),108 Instant.now().plusSeconds(getLong("expires_in"))109 )110 }111 }112}...

Full Screen

Full Screen

Reactor.kt

Source:Reactor.kt Github

copy

Full Screen

1package com.github.kittinunf.fuel.reactor2import com.github.kittinunf.fuel.core.Deserializable3import com.github.kittinunf.fuel.core.FuelError4import com.github.kittinunf.fuel.core.Request5import com.github.kittinunf.fuel.core.Response6import com.github.kittinunf.fuel.core.deserializers.ByteArrayDeserializer7import com.github.kittinunf.fuel.core.deserializers.EmptyDeserializer8import com.github.kittinunf.fuel.core.deserializers.StringDeserializer9import com.github.kittinunf.fuel.core.requests.CancellableRequest10import com.github.kittinunf.fuel.core.response11import com.github.kittinunf.result.Result12import reactor.core.publisher.Mono13import reactor.core.publisher.MonoSink14import java.nio.charset.Charset15private fun <T : Any> Request.monoResult(async: Request.(MonoSink<T>) -> CancellableRequest): Mono<T> =16 Mono.create<T> { sink ->17 val cancellableRequest = async(sink)18 sink.onCancel { cancellableRequest.cancel() }19 }20private fun <T : Any> Request.monoResultFold(mapper: Deserializable<T>): Mono<T> =21 monoResult { sink ->22 response(mapper) { _, _, result ->23 result.fold(sink::success, sink::error)24 }25 }26private fun <T : Any> Request.monoResultUnFolded(mapper: Deserializable<T>): Mono<Result<T, FuelError>> =27 monoResult { sink ->28 response(mapper) { _, _, result ->29 sink.success(result)30 }31 }32/**33 * Get a single [Response]34 * @return [Mono<Response>] the [Mono]35 */36fun Request.monoResponse(): Mono<Response> =37 monoResult { sink ->38 response { _, res, _ -> sink.success(res) }39 }40/**41 * Get a single [ByteArray] via a [MonoSink.success], or any [FuelError] via [MonoSink.error]42 *43 * @see monoResultBytes44 * @return [Mono<ByteArray>] the [Mono]45 */46fun Request.monoBytes(): Mono<ByteArray> = monoResultFold(ByteArrayDeserializer())47/**48 * Get a single [String] via a [MonoSink.success], or any [FuelError] via [MonoSink.error]49 *50 * @see monoResultString51 *52 * @param charset [Charset] the charset to use for the string, defaults to [Charsets.UTF_8]53 * @return [Mono<String>] the [Mono]54 */55fun Request.monoString(charset: Charset = Charsets.UTF_8): Mono<String> = monoResultFold(StringDeserializer(charset))56/**57 * Get a single [T] via a [MonoSink.success], or any [FuelError] via [MonoSink.error]58 *59 * @see monoResultObject60 *61 * @param mapper [Deserializable<T>] the deserializable that can turn the response int a [T]62 * @return [Mono<T>] the [Mono]63 */64fun <T : Any> Request.monoObject(mapper: Deserializable<T>): Mono<T> = monoResultFold(mapper)65/**66 * Get a single [ByteArray] or [FuelError] via [Result]67 *68 * @see monoBytes69 * @return [Mono<Result<ByteArray, FuelError>>] the [Mono]70 */71fun Request.monoResultBytes(): Mono<Result<ByteArray, FuelError>> =72 monoResultUnFolded(ByteArrayDeserializer())73/**74 * Get a single [String] or [FuelError] via [Result]75 *76 * @see monoString77 *78 * @param charset [Charset] the charset to use for the string, defaults to [Charsets.UTF_8]79 * @return [Mono<Result<ByteArray, FuelError>>] the [Mono]80 */81fun Request.monoResultString(charset: Charset = Charsets.UTF_8): Mono<Result<String, FuelError>> =82 monoResultUnFolded(StringDeserializer(charset))83/**84 * Get a single [T] or [FuelError] via [Result]85 *86 * @see monoObject87 * @return [Mono<Result<T, FuelError>>] the [Mono]88 */89fun <T : Any> Request.monoResultObject(mapper: Deserializable<T>): Mono<Result<T, FuelError>> =90 monoResultUnFolded(mapper)91/**92 * Get a complete signal(success with [Unit]) via a [MonoSink.success], or any [FuelError] via [MonoSink.error]93 */94fun Request.monoUnit(): Mono<Unit> = monoResultFold(EmptyDeserializer)...

Full Screen

Full Screen

Request.monoResponse

Using AI Code Generation

copy

Full Screen

1val monoResponse = request.monoResponse()2val monoResponseResult = request.monoResponseResult()3val monoResponseObject = request.monoResponseObject()4val monoResponseList = request.monoResponseList()5val monoResponseString = request.monoResponseString()6val monoResponseBytes = request.monoResponseBytes()7val monoResponseFile = request.monoResponseFile()8val monoResponseStream = request.monoResponseStream()9val monoResponseJson = request.monoResponseJson()10val monoResponseXml = request.monoResponseXml()11val monoResponseXml = request.monoResponseXml()12val monoResponseXml = request.monoResponseXml()13val monoResponseXml = request.monoResponseXml()14val monoResponseXml = request.monoResponseXml()

Full Screen

Full Screen

Request.monoResponse

Using AI Code Generation

copy

Full Screen

1import com.github.kittinunf.fuel.reactor.monoResponse2import com.github.kittinunf.fuel.reactor.monoStringResponse3import com.github.kittinunf.fuel.reactor.reactor4import com.github.kittinunf.fuel.reactor.reactorString5import reactor.core.publisher.Mono6import com.github.kittinunf.fuel.rx.rxResponse7import com.github.kittinunf.fuel.rx.rxStringResponse8import io.reactivex.Single9import com.github.kittinunf.fuel.rx2.rxResponse10import com.github.kittinunf.fuel.rx2.rxStringResponse11import io.reactivex.Single12import com.github.kittinunf.fuel.rx3.rxResponse13import com.github.kittinunf.fuel.rx3.rxStringResponse14import io.reactivex.rxjava3.core.Single

Full Screen

Full Screen

Request.monoResponse

Using AI Code Generation

copy

Full Screen

1val response = request.monoResponse().block()2val response = request.monoResponseObject(DeserializableOf(::String)).block()3val response = request.monoResponseObject(String::class.java).block()4val response = request.monoResponseObject(String::class.java, "application/json").block()5val response = request.monoResponseObject(String::class.java, listOf("application/json")).block()6val response = request.monoResponseObject(String::class.java, "application/json", "application/xml").block()7val response = request.monoResponseObject(String::class.java, listOf("application/json", "application/xml")).block()8val response = request.monoResponseObject(String::class.java, { it.contentLength() }, "application/json").block()9val response = request.monoResponseObject(String::class.java, { it.contentLength() },

Full Screen

Full Screen

Request.monoResponse

Using AI Code Generation

copy

Full Screen

1val response = request . monoResponse ( reactorClient )2val response = request . monoResponseObject ( reactorClient )3val response = request . monoResponseString ( reactorClient )4val response = request . monoResponseByteArray ( reactorClient )5val response = request . monoResponse ( reactorClient )6val response = request . monoResponseObject ( reactorClient )7val response = request . monoResponseString ( reactorClient )8val response = request . monoResponseByteArray ( reactorClient )9val response = request . monoResponse ( reactorClient )10val response = request . monoResponseObject ( reactorClient )11val response = request . monoResponseString ( reactorClient )12val response = request . monoResponseByteArray ( reactorClient )13val response = request . monoResponse ( reactor

Full Screen

Full Screen

Request.monoResponse

Using AI Code Generation

copy

Full Screen

1request.subscribe { result ->2println(result.component1()?.body()?.asString("application/json"))3}4request.subscribe { result ->5println(result.component1()?.body()?.asString("application/json"))6}7request.subscribe { result ->8println(result.component1()?.body()?.asString("application/json"))9}10request.subscribe { result ->11println(result.component1()?.body()?.asString("application/json"))12}13request.subscribe { result ->14println(result.component1()?.body()?.asString("application/json"))15}16request.subscribe { result ->17println(result.component1()?.body()?.asString("application/json"))18}19request.subscribe { result ->20println(result.component1()?.body()?.asString("application/json"))21}22request.subscribe { result ->23println(result.component1()?.body()?.asString("application/json"))24}

Full Screen

Full Screen

Request.monoResponse

Using AI Code Generation

copy

Full Screen

1FuelManager.instance.baseHeaders = mapOf("X-Auth-Token" to "xxxxxx")2FuelManager.instance.baseHeaders = mapOf("X-Auth-Token" to "xxxxxx")3FuelManager.instance.baseHeaders = mapOf("X-Auth-Token" to "xxxxxx")4FuelManager.instance.baseHeaders = mapOf("X-Auth-Token" to "xxxxxx")5FuelManager.instance.baseHeaders = mapOf("X-Auth-Token" to "xxxxxx")6FuelManager.instance.baseHeaders = mapOf("X-Auth-Token" to "xxxxxx")7FuelManager.instance.baseHeaders = mapOf("X-Auth-Token" to "xxxxxx")8FuelManager.instance.baseHeaders = mapOf("X-Auth-Token" to "xxxxxx")9val (request, response, result) = "

Full Screen

Full Screen

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Fuel automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Most used method in Reactor

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful