How to use wrap method of com.github.kittinunf.fuel.core.FuelError class

Best Fuel code snippet using com.github.kittinunf.fuel.core.FuelError.wrap

Deserializable.kt

Source:Deserializable.kt

...37                ?: deserialize(stream.reader())38                ?: reserialize(response, stream).let {39                    deserialize(response.data)40                        ?: deserialize(String(response.data))41                        ?: throw FuelError.wrap(IllegalStateException(42                            "One of deserialize(ByteArray) or deserialize(InputStream) or deserialize(Reader) or " +43                                "deserialize(String) must be implemented"44                        ))45                }46        }47    }48    private fun reserialize(response: Response, stream: InputStream): Response {49        val length = response.body.length50        response.body = DefaultBody.from({ stream }, length?.let { l -> { l } })51        return response52    }53    /**54     * Deserialize into [T] from an [InputStream]55     *56     * @param inputStream [InputStream] source bytes57     * @return [T] deserialized instance of [T] or null when not applied58     */59    fun deserialize(inputStream: InputStream): T? = null60    /**61     * Deserialize into [T] from a [Reader]62     *63     * @param reader [Reader] source bytes64     * @return [T] deserialized instance of [T] or null when not applied65     */66    fun deserialize(reader: Reader): T? = null67    /**68     * Deserialize into [T] from a [ByteArray]69     *70     * @note it is more efficient to implement the [InputStream] variant.71     *72     * @param bytes [ByteArray] source bytes73     * @return [T] deserialized instance of [T] or null when not applied74     */75    fun deserialize(bytes: ByteArray): T? = null76    /**77     * Deserialize into [T] from a [String]78     *79     * @note it is more efficient to implement the [Reader] variant.80     *81     * @param content [String] source bytes82     * @return [T] deserialized instance of [T] or null when not applied83     */84    fun deserialize(content: String): T? = null85}86/**87 * Deserialize the [Response] to the [this] into a [T] using [U]88 *89 * @see ResponseResultHandler90 *91 * @param deserializable [U] the instance that performs deserialization92 * @param handler [ResponseResultHandler<T>] handler that has a [Result]93 * @return [CancellableRequest] the request that can be cancelled94 */95fun <T : Any, U : Deserializable<T>> Request.response(deserializable: U, handler: ResponseResultHandler<T>): CancellableRequest =96    response(deserializable,97        { request, response, value -> handler(request, response, Result.Success(value)) },98        { request, response, error -> handler(request, response, Result.Failure(error)) }99    )100/**101 * Deserialize the [Response] to the [this] into a [T] using [U]102 *103 * @see ResultHandler104 *105 * @param deserializable [U] the instance that performs deserialization106 * @param handler [ResultHandler<T>] handler that has a [Result]107 * @return [CancellableRequest] the request that can be cancelled108 */109fun <T : Any, U : Deserializable<T>> Request.response(deserializable: U, handler: ResultHandler<T>): CancellableRequest =110    response(deserializable,111        { _, _, value -> handler(Result.Success(value)) },112        { _, _, error -> handler(Result.Failure(error)) }113    )114/**115 * Deserialize the [Response] to the [this] into a [T] using [U]116 *117 * @see ResponseHandler118 *119 * @param deserializable [U] the instance that performs deserialization120 * @param handler [ResponseHandler<T>] handler that has dedicated paths for success and failure121 * @return [CancellableRequest] the request that can be cancelled122 */123fun <T : Any, U : Deserializable<T>> Request.response(deserializable: U, handler: ResponseHandler<T>): CancellableRequest =124    response(deserializable,125        { request, response, value -> handler.success(request, response, value) },126        { request, response, error -> handler.failure(request, response, error) }127    )128/**129 * Deserialize the [Response] to the [this] into a [T] using [U]130 *131 * @see Handler132 *133 * @param deserializable [U] the instance that performs deserialization134 * @param handler [Handler<T>] handler that has dedicated paths for success and failure135 * @return [CancellableRequest] the request that can be cancelled136 */137fun <T : Any, U : Deserializable<T>> Request.response(deserializable: U, handler: Handler<T>): CancellableRequest =138    response(deserializable,139        { _, _, value -> handler.success(value) },140        { _, _, error -> handler.failure(error) }141    )142/**143 * Deserialize the [Response] to the [this] into a [T] using [U]144 *145 * @note not async, use the variations with a handler instead.146 *147 * @throws Exception if there is an internal library error, not related to Network or Deserialization148 *149 * @param deserializable [U] the instance that performs deserialization150 * @return [ResponseResultOf<T>] the response result of151 */152fun <T : Any, U : Deserializable<T>> Request.response(deserializable: U): ResponseResultOf<T> {153    // First execute the network request and catch any issues154    val rawResponse = runCatching { toTask().call() }155        .onFailure { error ->156            FuelError.wrap(error, Response.error(url)).also {157                return Triple(this, it.response, Result.error(it))158            }159        }160        .getOrThrow()161    // By this time it should have a response, but deserialization might fail162    return runCatching { Triple(this, rawResponse, Result.Success(deserializable.deserialize(rawResponse))) }163        .recover { error -> Triple(this, rawResponse, Result.Failure(FuelError.wrap(error, rawResponse))) }164        .getOrThrow()165}166/**167 * Ignore the response result168 *169 * Use this method to avoid huge memory allocation when using [com.github.kittinunf.fuel.core.requests.download]170 * to a large download and without using the result [ByteArray]171 *172 * @see [com.github.kittinunf.fuel.core.Request.response]173 *174 * @note not async, use the variations with a handler instead.175 *176 * @throws Exception if there is an internal library error, not related to Network177 */178fun Request.responseUnit(): ResponseResultOf<Unit> = response(EmptyDeserializer)179private fun <T : Any, U : Deserializable<T>> Request.response(180    deserializable: U,181    success: (Request, Response, T) -> Unit,182    failure: (Request, Response, FuelError) -> Unit183): CancellableRequest {184    val asyncRequest = RequestTaskCallbacks(185        request = this,186        onSuccess = { response ->187            // The network succeeded but deserialization might fail188            val deliverable = Result.of<T, Exception> { deserializable.deserialize(response) }189            executionOptions.callback {190                deliverable.fold(191                    { success(this, response, it) },192                    { failure(this, response, FuelError.wrap(it, response).also { error ->193                        Fuel.trace { "[Deserializable] unfold failure: \n\r$error" } })194                    }195                )196            }197        },198        onFailure = { error, response ->199            executionOptions.callback {200                failure(this, response, error.also { error ->201                    Fuel.trace { "[Deserializable] callback failure: \n\r$error" }202                })203            }204        }205    )206    return CancellableRequest.enableFor(this, future = executionOptions.submit(asyncRequest))207}208/**209 * Await [T] or throws [FuelError]210 * @return [T] the [T]211 */212@Throws(FuelError::class)213suspend fun <T : Any, U : Deserializable<T>> Request.await(deserializable: U): T {214    val response = suspendable().await()215    return runCatching { deserializable.deserialize(response) }216        .onFailure { throw FuelError.wrap(it, response) }217        .getOrThrow()218}219/**220 * Await the task or throws [FuelError] in current coroutine context.221 *222 * Use this method to avoid huge memory allocation when using [com.github.kittinunf.fuel.core.requests.download]223 * to a large file without using response result224 *225 * To run method in different coroutine context, use `com.github.kittinunf.fuel.coroutines.awaitUnit` in `fuel-coroutines` module226 */227@Throws(FuelError::class)228suspend fun Request.awaitUnit(): Unit = await(EmptyDeserializer)229/**230 * Await [T] or [FuelError]231 * @return [ResponseOf<T>] the [Result] of [T]232 */233@Throws(FuelError::class)234suspend fun <T : Any, U : Deserializable<T>> Request.awaitResponse(deserializable: U): ResponseOf<T> {235    val response = suspendable().await()236    return runCatching { Triple(this, response, deserializable.deserialize(response)) }237        .onFailure { throw FuelError.wrap(it, response) }238        .getOrThrow()239}240/**241 * Await [T] or [FuelError]242 * @return [Result<T>] the [Result] of [T]243 */244suspend fun <T : Any, U : Deserializable<T>> Request.awaitResult(deserializable: U): Result<T, FuelError> {245    val initialResult = suspendable().awaitResult()246    return serializeFor(initialResult, deserializable).map { (_, t) -> t }247}248/**249 * Await [T] or [FuelError]250 * @return [ResponseResultOf<T>] the [ResponseResultOf] of [T]251 */252suspend fun <T : Any, U : Deserializable<T>> Request.awaitResponseResult(deserializable: U): ResponseResultOf<T> {253    val initialResult = suspendable().awaitResult()254    return serializeFor(initialResult, deserializable).let {255            Triple(this,256                it.fold({ (response, _) -> response }, { error -> error.response }),257                it.map { (_, t) -> t }258            )259        }260}261private fun <T : Any, U : Deserializable<T>> serializeFor(result: Result<Response, FuelError>, deserializable: U) =262    result.map { (it to deserializable.deserialize(it)) }263        .mapError <Pair<Response, T>, Exception, FuelError> {264            FuelError.wrap(it, result.getOrElse { Response.error() })265        }...

ObjectTest.kt

Source:ObjectTest.kt

...23private object UUIDResponseDeserializer : ResponseDeserializable<UUIDResponse> {24    class NoValidFormat(m: String = "Not a UUID") : Exception(m)25    override fun deserialize(content: String): UUIDResponse {26        if (content.contains("=") || !content.contains("-")) {27            throw FuelError.wrap(NoValidFormat())28        }29        return UUIDResponse(content)30    }31}32class ObjectTest : MockHttpTestCase() {33    private fun randomUUID() = UUID.randomUUID()34    private fun getUUID(uuid: UUID, path: String = "uuid"): Request {35        mock.chain(36            request = mock.request().withPath("/$path"),37            response = mock.response().withBody(uuid.toString())38        )39        return Fuel.request(Method.GET, mock.path(path))40    }41    private fun mocked404(method: Method = Method.GET, path: String = "invalid/url"): Request {...

Models.kt

Source:Models.kt

...43            val bitmap: Bitmap? = BitmapFactory.decodeByteArray(it, 0, it.size)44            if (bitmap != null) {45                handler(Result.success(bitmap))46            } else {47                handler(Result.error(FuelError.wrap(NullPointerException()))) // å¯è½æ¯å¼ gifï¼ä¸æ¯æ48            }49            return50        }51        news.imageList[which].httpGet().response { _, _, result ->52            result.map { BitmapFactory.decodeByteArray(it, 0, it.size) }.apply(handler)53            result.success { imageDataList[which] = it }54        }55    }56    // è°ç¨èä¿è¯news.videoéç©º57    // handlerå¤ççæ¯è§é¢æä»¶å(å ä¸ºè§é¢ææ¾å¨åºä¸æ¥åè§é¢åå®¹ï¼åªæ¥åurl)58    inline fun downloadVideo(crossinline handler: (String) -> Unit) {59        val video = news.video!!60        val videoPath = videoPath ?: run {61            handler(video) // å¦ææ²¡ææ¬å°ä¸è½½ï¼åç´æ¥ææ¾videoç½å(è¿æ ·ç¨æ·ä¸éè¦çå¾)...

SuspendableRequest.kt

Source:SuspendableRequest.kt

...7import 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    }...

HttpUpstream.kt

Source:HttpUpstream.kt

...68        return retryGet(url)69      }70      result71    } catch (e: Exception) {72      Result.error(FuelError.wrap(e))73    }74  }75  private suspend fun retryGet(url: String): Result<R, FuelError> {76    return try {77      return if (HTTP.refresh()) {78        val request = Fuel.get(mustNormalizeUrl(url)).apply {79          if (!Settings.isAnonymous()) {80            header("Authorization", "Bearer ${Settings.getAccessToken()}")81          }82        }83        request.awaitObjectResult(GenericDeserializer(type))84      } else {85        Result.Failure(FuelError.wrap(RefreshError))86      }87    } catch (e: Exception) {88      Result.error(FuelError.wrap(e))89    }90  }91}...

Data.kt

Source:Data.kt

...48        }49      }50      request.awaitObjectResult(gsonDeserializerOf(T::class.java))51    } else {52      Result.Failure(FuelError.wrap(RefreshError))53    }54  }55}56object Cache {57  private fun key(key: String): String {58    val md = MessageDigest.getInstance("SHA-1")59    val digest = md.digest(key.toByteArray(Charset.defaultCharset()))60    return digest.fold("", { acc, it -> acc + "%02x".format(it) })61  }62  fun set(context: Context?, key: String, value: ByteArray) = context?.let {63    with(File(it.cacheDir, key(key))) {64      writeBytes(value)65    }66  }...

RequestTask.kt

Source:RequestTask.kt

...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)...

RequestTaskCallbacks.kt

Source:RequestTaskCallbacks.kt

...23    override fun call(): Response {24        Fuel.trace { "[RequestTaskCallbacks] start request task\n\r\t$request" }25        return runCatching { task.call() }26            .mapCatching { it -> it.also { onSuccess(it) } }27            .getOrElse { error -> FuelError.wrap(error).also { onFailure(it, it.response) }.response }28    }29}...

wrap

Using AI Code Generation

1val  wrappedError = error . wrap () 2 println (wrappedError)3val  unwrappedError = wrappedError . unwrap () 4 println (unwrappedError)5val  error =  Exception ( "Exception occurred" ) . asError () 6 println (error)7 val  error =  Exception ( "Exception occurred" ) . asError () 8 println (error . exception ) 9 println (error . exception ) 10 println (error . response ) 11 println (error . response ) 12 println (error . request ) 13 println (error . request ) 14 println (error . message ) 15 println (error . message ) 16 println (error . isDeserializationError ) 17 println (error . isDeserializationError ) 18 println (error . isServerError ) 19 println (error . isServerError ) 20 println (error . isClientError ) 21 println (error . isClientError ) 22 println (error . isConnectionError ) 23 println (error . isConnectionError ) 24 println (error . isResponseError ) 25 println (error . isResponseError ) 26 println (error . isRequestError ) 27 println (error . isRequestError ) 28 println (error . isOtherError ) 29 println (error . isOtherError )30 val  error =  Exception ( "Exception occurred" ) . asError () 31 println (error . wrap ()) 32 println (error . wrap ()) 33 println (error . wrap (). unwrap ()) 34 println (error . wrap (). unwrap ()) 35 println (error . wrap (). unwrap (). wrap ()) 36 println (error . wrap (). unwrap (). wrap

wrap

Using AI Code Generation

1val error = result.third.get()2println(error.wrap())3val error = result.third.get()4println(error.wrap())5val error = result.third.get()6println(error.wrap())7val error = result.third.get()8println(error.wrap())9val error = result.third.get()10println(error.wrap())11val error = result.third.get()12println(error.wrap())13val error = result.third.get()14println(error.wrap())15val error = result.third.get()16println(error.wrap())17val error = result.third.get()18println(error.wrap())19val error = result.third.get()20println(error.wrap())

wrap

Using AI Code Generation

1val error = FuelError (Exception( "Something went wrong" ))2val wrappedError = error .wrap( "This is a wrapped error" )3println(wrappedError.message)4val error = FuelError (Exception( "Something went wrong" ))5val wrappedError = error .wrap( "This is a wrapped error" )6val unwrappedError = wrappedError.unwrap()7println(unwrappedError.message)8val error = FuelError (Exception( "Something went wrong" ))9val wrappedError = error .wrap( "This is a wrapped error" )10val unwrappedError = wrappedError.unwrap()11println(unwrappedError.message)12val error = FuelError (Exception( "Something went wrong" ))13val wrappedError = error .wrap( "This is a wrapped error" )14val unwrappedError = wrappedError.unwrap()15println(unwrappedError.message)16val error = FuelError (Exception( "Something went wrong" ))17val wrappedError = error .wrap( "This is a wrapped error" )18val unwrappedError = wrappedError.unwrap()19println(unwrappedError.message)20val error = FuelError (Exception( "Something went wrong" ))21val wrappedError = error .wrap( "This is a wrapped error" )22val unwrappedError = wrappedError.unwrap()23println(unwrappedError.message)24val error = FuelError (Exception( "Something went wrong" ))25val wrappedError = error .wrap( "This is a wrapped error" )26val unwrappedError = wrappedError.unwrap()27println(unwrappedError.message)28val error = FuelError (Exception( "Something went wrong" ))29val wrappedError = error .wrap( "This is a wrapped error" )

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.