Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use RequestTask class of com.github.kittinunf.fuel.core.requests package

Best Fuel code snippet using com.github.kittinunf.fuel.core.requests.RequestTask

SuspendableRequest.kt

Source:SuspendableRequest.kt

...5import com.github.kittinunf.fuel.core.Request6import com.github.kittinunf.fuel.core.Response7import com.github.kittinunf.result.Result8/**9 * Coroutine version of [RequestTask]. Turns a [Request] into an executable, suspendable, coroutine.10 */11class SuspendableRequest private constructor(private val wrapped: Request) : Request by wrapped {12    private val interruptCallback by lazy { executor.interruptCallback }13    private val executor by lazy { request.executionOptions }14    private val client by lazy { executor.client }15    private fun prepareRequest(request: Request): Request = executor.requestTransformer(request)16    private suspend fun executeRequest(request: Request): Pair<Request, Response> {17        return runCatching { Pair(request, client.awaitRequest(request)) }18            .recover { error -> throw FuelError.wrap(error, Response(url)) }19            .getOrThrow()20    }21    private fun prepareResponse(result: Pair<Request, Response>): Response {22        val (request, response) = result23        return runCatching { executor.responseTransformer(request, response) }24            .mapCatching { transformedResponse ->25                val valid = executor.responseValidator(transformedResponse)26                if (valid) transformedResponse27                else throw FuelError.wrap(HttpException(transformedResponse.statusCode, transformedResponse.responseMessage), transformedResponse)28            }29            .recover { error -> throw FuelError.wrap(error, response) }30            .getOrThrow()31    }32    suspend fun awaitResult(): Result<Response, FuelError> {33        return runCatching { prepareRequest(request) }34            .mapCatching { executeRequest(it) }35            .mapCatching { pair ->36                // Nested runCatching so response can be rebound37                runCatching { prepareResponse(pair) }38                    .recover { error ->39                        error.also { Fuel.trace { "[RequestTask] execution error\n\r\t$error" } }40                        throw FuelError.wrap(error, pair.second)41                    }42                    .getOrThrow()43            }44            .onFailure { error ->45                Fuel.trace { "[RequestTask] on failure ${(error as? FuelError)?.exception ?: error}" }46                if (error is FuelError && error.causedByInterruption) {47                    Fuel.trace { "[RequestTask] execution error\n\r\t$error" }48                    interruptCallback.invoke(request)49                }50            }51            .map { Result.Success(it) }52            .recover { Result.Failure(it as FuelError) }53            .getOrThrow()54    }55    @Throws(FuelError::class)56    suspend fun await(): Response {57        return awaitResult().get()58    }59    companion object {60        private val FEATURE = SuspendableRequest::class.java.canonicalName61        fun enableFor(request: Request): SuspendableRequest {...

RequestTask.kt

Source:RequestTask.kt

...4import com.github.kittinunf.fuel.core.HttpException5import com.github.kittinunf.fuel.core.Request6import com.github.kittinunf.fuel.core.Response7import java.util.concurrent.Callable8private typealias RequestTaskResult = Pair<Request, Response>9/**10 * Synchronous version of [SuspendableRequest]. Turns a [Request] into a [Callable]11 */12internal class RequestTask(internal val request: Request) : Callable<Response> {13    private val interruptCallback by lazy { executor.interruptCallback }14    private val executor by lazy { request.executionOptions }15    private val client by lazy { executor.client }16    private fun prepareRequest(request: Request): Request = executor.requestTransformer(request)17    @Throws(FuelError::class)18    private fun executeRequest(request: Request): RequestTaskResult {19        return runCatching { Pair(request, client.executeRequest(request)) }20            .recover { error -> throw FuelError.wrap(error, Response(request.url)) }21            .getOrThrow()22    }23    @Throws(FuelError::class)24    private fun prepareResponse(result: RequestTaskResult): Response {25        val (request, response) = result26        return runCatching { executor.responseTransformer(request, response) }27            .mapCatching { transformedResponse ->28                val valid = executor.responseValidator(transformedResponse)29                if (valid) transformedResponse30                else throw FuelError.wrap(HttpException(transformedResponse.statusCode, transformedResponse.responseMessage), transformedResponse)31            }32            .recover { error -> throw FuelError.wrap(error, response) }33            .getOrThrow()34    }35    @Throws(FuelError::class)36    override fun call(): Response {37        return runCatching { prepareRequest(request) }38            .mapCatching { executeRequest(it) }39            .mapCatching { pair ->40                // Nested runCatching so response can be rebound41                runCatching { prepareResponse(pair) }42                    .recover { error ->43                        error.also { Fuel.trace { "[RequestTask] execution error\n\r\t$error" } }44                        throw FuelError.wrap(error, pair.second)45                    }46                    .getOrThrow()47            }48            .onFailure { error ->49                Fuel.trace { "[RequestTask] on failure (interrupted=${(error as? FuelError)?.causedByInterruption ?: error})" }50                if (error is FuelError && error.causedByInterruption) {51                    Fuel.trace { "[RequestTask] execution error\n\r\t$error" }52                    interruptCallback.invoke(request)53                }54            }55            .getOrThrow()56    }57}58internal fun Request.toTask(): Callable<Response> = RequestTask(this)...

RequestTask

Using AI Code Generation

1request.run()2val (data, error) = request.response3if (error != null) {4println(error)5} else {6println(String(data))7}8request.run()9val (data, error) = request.response10if (error != null) {11println(error)12} else {13println(String(data))14}15}16}

RequestTask

Using AI Code Generation

1val requestTask = RequestTask()2requestTask.execute()3val requestTask = RequestTask()4requestTask.execute()5val requestTask = RequestTask()6requestTask.execute()7val requestTask = RequestTask()8requestTask.execute()9val requestTask = RequestTask()10requestTask.execute()11val requestTask = RequestTask()12requestTask.execute()13val requestTask = RequestTask()14requestTask.execute()15val requestTask = RequestTask()16requestTask.execute()17val requestTask = RequestTask()18requestTask.execute()19val requestTask = RequestTask()20requestTask.execute()

RequestTask

Using AI Code Generation

1request.headers.append("Content-Type", "application/json")2request.parameters.append("hello", "world")3request.execute()4val responseAsString = response.string()5val responseAsJson = response.json()6val responseAsBytes = response.bytes()7val responseAsFile = response.file()8val responseAsBitmap = response.bitmap()9val responseAsDrawable = response.drawable()10val responseAsInputStream = response.inputStream()11val responseAsReader = response.reader()12val responseAsSource = response.source()13val responseAsSink = response.sink()14val responseAsBufferedSink = response.bufferedSink()15val responseAsBufferedSource = response.bufferedSource()16val responseAsImage = response.image()17val responseAsBitmap = response.bitmap()18val responseAsDrawable = response.drawable()19val responseAsView = response.view()20val responseAsJsonArray = response.jsonArray()21val responseAsJsonObject = response.jsonObject()22val responseAsXml = response.xml()23val responseAsXmlDocument = response.xmlDocument()24val responseAsXmlElement = response.xmlElement()25val responseAsXmlNode = response.xmlNode()26val responseAsXmlText = response.xmlText()27val responseAsXmlComment = response.xmlComment()

RequestTask

Using AI Code Generation

1request.responseString { request, response, result ->2when(result) {3is Result.Failure -> {4val ex = result.getException()5}6is Result.Success -> {7val data = result.get()8}9}10}11request.responseString { request, response, result ->12when(result) {13is Result.Failure -> {14val ex = result.getException()15}16is Result.Success -> {17val data = result.get()18}19}20}

RequestTask

Using AI Code Generation

1RequestTask().execute { 2        .responseString { request, response, result ->3            val (data, error) = result4        }5}6val customManager = FuelManager().apply {7    baseHeaders = mapOf("Accept" to "application/json")8    baseParams = listOf("key" to "value")9    baseHeaders = mapOf("Accept" to "application/json")10    baseParams = listOf("key" to "value")11    baseHeaders = mapOf("Accept" to "application/json")12    baseParams = listOf("key" to "value")13    baseHeaders = mapOf("Accept" to "application/json")14    baseParams = listOf("key" to "value")15    baseHeaders = mapOf("Accept" to "application/json")16    baseParams = listOf("key" to "value")17    baseHeaders = mapOf("Accept" to "application/json")18    baseParams = listOf("key" to "value")19    baseHeaders = mapOf("Accept" to "application/json")20    baseParams = listOf("key" to "value")21    baseHeaders = mapOf("Accept" to "application/json")22    baseParams = listOf("key" to "value")23    baseHeaders = mapOf("Accept" to "application/json")24    baseParams = listOf("key" to "value")25    baseHeaders = mapOf("Accept" to "application/json")

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.