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

Copied to Clipboard!

How to use coerceMethod method of com.github.kittinunf.fuel.toolbox.HttpClient class

Best Fuel code snippet using com.github.kittinunf.fuel.toolbox.HttpClient.coerceMethod

HttpClient.kt

Source:HttpClient.kt

...83            	hostnameVerifier = request.executionOptions.hostnameVerifier84            }85            if (request.executionOptions.forceMethods) {86                forceMethod(request.method)87                // If setting method via reflection failed, invoke "coerceMethod"88                // and set "X-HTTP-Method-Override" header89                if (this.requestMethod !== request.method.value) {90                    this.requestMethod = coerceMethod(request.method).value91                    this.setRequestProperty("X-HTTP-Method-Override", request.method.value)92                }93            } else {94                requestMethod = coerceMethod(request.method).value95                if (request.method.value == "PATCH") {96                    setRequestProperty("X-HTTP-Method-Override", request.method.value)97                }98            }99            doInput = true100            useCaches = request.executionOptions.useHttpCache ?: useHttpCache101            instanceFollowRedirects = false102            request.headers.transformIterate(103                { key, values -> setRequestProperty(key, values) },104                { key, value -> addRequestProperty(key, value) }105            )106            // By default, the Android implementation of HttpURLConnection requests that servers use gzip compression107            //   and it automatically decompresses the data for callers of URLConnection.getInputStream().108            //   The Content-Encoding and Content-Length response headers are cleared in this case. Gzip compression can109            //   be disabled by setting the acceptable encodings in the request header:110            //111            //      .header(Headers.ACCEPT_ENCODING, "identity")112            //113            // However, on the JVM, this behaviour might be different. Content-Encoding SHOULD NOT be used, in HTTP/1x114            //  to act as Transfer Encoding. In HTTP/2, Transfer-Encoding is not part of the Connection field and should115            //  not be injected here. HttpURLConnection is only HTTP/1x, whereas Java 9 introduces a new HttpClient for116            //  HTTP/2.117            //118            // This adds the TE header for HTTP/1 connections, and automatically decodes it using decodeTransfer.119            // The TE (Accept Transfer Encoding) can only be one of these, should match decodeTransfer.120            setRequestProperty(121                Headers.ACCEPT_TRANSFER_ENCODING,122                Headers.collapse(HeaderName(Headers.ACCEPT_TRANSFER_ENCODING), SUPPORTED_DECODING)123            )124            hook.preConnect(connection, request)125            setDoOutput(connection, request.method)126            setBodyIfDoOutput(connection, request)127        }128        // Ensure that we are connected after this point. Note that getOutputStream above will129        // also connect and exchange HTTP messages.130        connection.connect()131    }132    @Throws(IOException::class, InterruptedException::class)133    private fun retrieveResponse(request: Request, connection: HttpURLConnection): Response {134        ensureRequestActive(request, connection)135        hook.postConnect(request)136        val headers = Headers.from(connection.headerFields)137        val transferEncoding = headers[Headers.TRANSFER_ENCODING].flatMap { it.split(',') }.map { it.trim() }138        val contentEncoding = headers[Headers.CONTENT_ENCODING].lastOrNull()139        var contentLength = headers[Headers.CONTENT_LENGTH].lastOrNull()?.toLong()140        val shouldDecode = (request.executionOptions.decodeContent ?: decodeContent) && contentEncoding != null && contentEncoding != "identity"141        if (shouldDecode) {142            // `decodeContent` decodes the response, so the final response has no more `Content-Encoding`143            headers.remove(Headers.CONTENT_ENCODING)144            // URLConnection.getContentLength() returns the number of bytes transmitted and cannot be used to predict145            // how many bytes can be read from URLConnection.getInputStream() for compressed streams. Therefore if the146            // stream will be decoded, the length becomes unknown147            //148            headers.remove(Headers.CONTENT_LENGTH)149            contentLength = null150        }151        // `decodeTransfer` decodes the response, so the final response has no more Transfer-Encoding152        headers.remove(Headers.TRANSFER_ENCODING)153        // [RFC 7230, 3.3.2](https://tools.ietf.org/html/rfc7230#section-3.3.2)154        //155        // When a message does not have a Transfer-Encoding header field, a156        //   Content-Length header field can provide the anticipated size, as a157        //   decimal number of octets, for a potential payload body.158        //159        //   A sender MUST NOT send a Content-Length header field in any message160        //   that contains a Transfer-Encoding header field.161        //162        // [RFC 7230, 3.3.3](https://tools.ietf.org/html/rfc7230#section-3.3.3)163        //164        // Any 2xx (Successful) response to a CONNECT request implies that165        //   the connection will become a tunnel immediately after the empty166        //   line that concludes the header fields.  A client MUST ignore any167        //   Content-Length or Transfer-Encoding header fields received in168        //   such a message.169        //170        if (transferEncoding.any { encoding -> encoding.isNotBlank() && encoding != "identity" }) {171            headers.remove(Headers.CONTENT_LENGTH)172            contentLength = -1173        }174        val contentStream = dataStream(request, connection)?.decode(transferEncoding) ?: ByteArrayInputStream(ByteArray(0))175        val inputStream = if (shouldDecode && contentEncoding != null) contentStream.decode(contentEncoding) else contentStream176        val cancellationConnection = WeakReference<HttpURLConnection>(connection)177        val progressStream = ProgressInputStream(178            inputStream, onProgress = { readBytes ->179                request.executionOptions.responseProgress(readBytes, contentLength ?: readBytes)180                ensureRequestActive(request, cancellationConnection.get())181            }182        )183        // The input and output streams returned by connection are not buffered. In order to give consistent progress184        // reporting, by means of flushing, the input stream here is buffered.185        return Response(186            url = request.url,187            headers = headers,188            contentLength = contentLength ?: -1,189            statusCode = connection.responseCode,190            responseMessage = connection.responseMessage.orEmpty(),191            body = DefaultBody.from(192                { progressStream.buffered(FuelManager.progressBufferSize) },193                { contentLength ?: -1 }194            )195        )196    }197    private fun dataStream(request: Request, connection: HttpURLConnection): InputStream? = try {198        hook.interpretResponseStream(request, connection.inputStream)?.buffered()199    } catch (_: IOException) {200        hook.interpretResponseStream(request, connection.errorStream)?.buffered()201    }202    private fun establishConnection(request: Request): HttpURLConnection {203        val url = request.url204        val connection = proxy?.let { url.openConnection(it) } ?: url.openConnection()205        return connection as HttpURLConnection206    }207    private fun setBodyIfDoOutput(connection: HttpURLConnection, request: Request) {208        val body = request.body209        if (!connection.doOutput) {210            return211        }212        if (body.isEmpty()) {213            connection.setFixedLengthStreamingMode(0L)214            return215        }216        val contentLength = body.length217        if (contentLength != null && contentLength != -1L) {218            // The content has a known length, so no need to chunk219            connection.setFixedLengthStreamingMode(contentLength.toLong())220        } else {221            // The content doesn't have a known length, so turn it into chunked222            connection.setChunkedStreamingMode(4096)223        }224        val noProgressHandler = request.executionOptions.requestProgress.isNotSet()225        val outputStream = if (noProgressHandler) {226            // No need to report progress, let's just send the payload without buffering227            connection.outputStream228        } else {229            // The input and output streams returned by connection are not buffered. In order to give consistent progress230            // reporting, by means of flushing, the output stream here is buffered.231            val totalBytes = if ((contentLength ?: -1L).toLong() > 0) { contentLength!!.toLong() } else { null }232            ProgressOutputStream(233                connection.outputStream,234                onProgress = { writtenBytes ->235                    request.executionOptions.requestProgress(writtenBytes, totalBytes ?: writtenBytes)236                    ensureRequestActive(request, connection)237                }238            ).buffered(FuelManager.progressBufferSize)239        }240        body.writeTo(outputStream)241        connection.outputStream.flush()242    }243    private fun setDoOutput(connection: HttpURLConnection, method: Method) = when (method) {244        Method.GET, Method.HEAD, Method.OPTIONS, Method.TRACE -> connection.doOutput = false245        Method.DELETE, Method.POST, Method.PUT, Method.PATCH -> connection.doOutput = true246    }247    companion object {248        private val SUPPORTED_DECODING = listOf("gzip", "deflate; q=0.5")249        private fun coerceMethod(method: Method) = if (method == Method.PATCH) Method.POST else method250    }251}...

coerceMethod

Using AI Code Generation

1val httpClient = HttpClient()2httpClient .coerceMethod("GET")3httpClient .coerceMethod("POST")4httpClient .coerceMethod("PUT")5httpClient .coerceMethod("HEAD")6httpClient .coerceMethod("DELETE")7httpClient .coerceMethod("PATCH")8httpClient .coerceMethod("TRACE")9httpClient .coerceMethod("OPTIONS")10httpClient .coerceMethod("CONNECT")11httpClient .coerceMethod("GET")12httpClient .coerceMethod("POST")13httpClient .coerceMethod("PUT")14httpClient .coerceMethod("HEAD")15httpClient .coerceMethod("DELETE")16httpClient .coerceMethod("PATCH")17httpClient .coerceMethod("TRACE")18httpClient .coerceMethod("OPTIONS")19httpClient .coerceMethod("CONNECT")20httpClient .coerceMethod("GET")21httpClient .coerceMethod("POST")22httpClient .coerceMethod("PUT")23httpClient .coerceMethod("HEAD")24httpClient .coerceMethod("DELETE")25httpClient .coerceMethod("PATCH")26httpClient .coerceMethod("TRACE")27httpClient .coerceMethod("OPTIONS")28httpClient .coerceMethod("CONNECT")29httpClient .coerceMethod("GET")30httpClient .coerceMethod("POST")31httpClient .coerceMethod("PUT")32httpClient .coerceMethod("HEAD")33httpClient .coerceMethod("DELETE")34httpClient .coerceMethod("PATCH")35httpClient .coerceMethod("TRACE")36httpClient .coerceMethod("OPTIONS")37httpClient .coerceMethod("CONNECT")38httpClient .coerceMethod("GET")39httpClient .coerceMethod("POST")40httpClient .coerceMethod("PUT")41httpClient .coerceMethod("HEAD")42httpClient .coerceMethod("DELETE")43httpClient .coerceMethod("PATCH")44httpClient .coerceMethod("TRACE")45httpClient .coerceMethod("OPTIONS")46httpClient .coerceMethod("CONNECT")47httpClient .coerceMethod("GET")48httpClient .coerceMethod("POST")49httpClient .coerceMethod("PUT")50httpClient .coerceMethod("HEAD")51httpClient .coerceMethod("DELETE")52httpClient .coerceMethod("PATCH")53httpClient .coerceMethod("TRACE")54httpClient .coerceMethod("OPTIONS")55httpClient .coerceMethod("CONNECT")56httpClient .coerceMethod("GET")57httpClient .coerceMethod("POST")58httpClient .coerceMethod("PUT")59httpClient .coerceMethod("HEAD")60httpClient .coerceMethod("DELETE")61httpClient .coerceMethod("PATCH")62httpClient .coerceMethod("TRACE")

coerceMethod

Using AI Code Generation

1import com.github.kittinunf.fuel.core.FuelManager2import com.github.kittinunf.fuel.core.Request3import com.github.kittinunf.fuel.core.Response4import com.github.kittinunf.fuel.core.requests.DefaultBody5import com.github.kittinunf.fuel.core.requests.DefaultRequest6import com.github.kittinunf.fuel.core.requests.RequestTransform7import com.github.kittinunf.fuel.core.requests.cUrlString8import com.github.kittinunf.fuel.core.requests.httpMethod9import com.github.kittinunf.fuel.core.requests.response10import com.github.kittinunf.fuel.core.requests.url11import com.github.kittinunf.fuel.httpPost12import com.github.kittinunf.fuel.toolbox.HttpClient13import com.github.kittinunf.result.Result14import java.io.OutputStream15import java.net.HttpURLConnection16import java.net.URL17fun main(args: Array<String>) {18    val json = "{ \"name\": \"John Doe\", \"occupation\": \"gardener\" }"19    val request = DefaultRequest()20    request.url = URL(url)21    request.body = DefaultBody(json)22    val httpClient = HttpClient()23    val response = httpClient.coerceMethod(request)24    println(response)25}26import com.github.kittinunf.fuel.core.FuelManager27import com.github.kittinunf.fuel.core.Request28import com.github.kittinunf.fuel.core.Response29import com.github.kittinunf.fuel.core.requests.DefaultBody30import com.github.kittinunf.fuel.core.requests.DefaultRequest31import com.github.kittinunf.fuel.core.requests.RequestTransform32import com.github.kittinunf.fuel.core.requests.cUrlString33import com.github.kittinunf.fuel.core.requests.httpMethod34import com.github.kittinunf.fuel.core.requests.response35import com.github.kittinunf.fuel.core.requests.url36import com.github.kittinunf.fuel.httpPost37import com.github.kittinunf.f

coerceMethod

Using AI Code Generation

1import com.github.kittinunf.fuel.toolbox.HttpClient2HttpClient.instance().coerceMethod("PUT")3HttpClient.instance().coerceMethod("delete")4import com.github.kittinunf.fuel.toolbox.HttpClient5HttpClient.instance().coerceMethod("PUT")6HttpClient.instance().coerceMetho

coerceMethod

Using AI Code Generation

1val  httpClient = HttpClient()2httpClient .coerceMethod(Method.GET)3httpClient .executeRequest(request).responseString()4val  httpClient = HttpClient()5httpClient .coerceMethod(Method.POST)6httpClient .executeRequest(request).responseString()7val  httpClient = HttpClient()8httpClient .coerceMethod(Method.PUT)9httpClient .executeRequest(request).responseString()10val  httpClient = HttpClient()11httpClient .coerceMethod(Method.PATCH)12httpClient .executeRequest(request).responseString()13val  httpClient = HttpClient()14httpClient .coerceMethod(Method.DELETE)15httpClient .executeRequest(request).responseString()16val  httpClient = HttpClient()17httpClient .coerceMethod(Method.HEAD)18httpClient .executeRequest(request).responseString()19val  httpClient = HttpClient()20httpClient .coerceMethod(Method.TRACE)21httpClient .executeRequest(request).responseString()22val  httpClient = HttpClient()23httpClient .coerceMethod(Method.CONNECT)24httpClient .executeRequest(request).responseString()25val  httpClient = HttpClient()26httpClient .coerceMethod(Method.OPTIONS)27httpClient .executeRequest(request).responseString()28val  httpClient = HttpClient()29httpClient .coerceMethod(Method.GET)30httpClient .executeRequest(request).responseString()

coerceMethod

Using AI Code Generation

1FuelManager.instance.baseHeaders = mapOf("X-TEST" to "test")2FuelManager.instance.baseParams = listOf("test" to "test")3FuelManager.instance.baseHeaders = mapOf("X-TEST" to "test")4FuelManager.instance.baseParams = listOf("test" to "test")5FuelManager.instance.baseHeaders = mapOf("X-TEST" to "test")6FuelManager.instance.baseParams = listOf("test" to "test")7FuelManager.instance.baseHeaders = mapOf("X-TEST" to "test")8FuelManager.instance.baseParams = listOf("test" to "test")9FuelManager.instance.baseHeaders = mapOf("X-TEST" to "test")10FuelManager.instance.baseParams = listOf("test" to "test")11FuelManager.instance.baseHeaders = mapOf("X-TEST" to "test")12FuelManager.instance.baseParams = listOf("test" to "test")13FuelManager.instance.baseHeaders = mapOf("X-TEST" to "test")14FuelManager.instance.baseParams = listOf("test" to "test")15FuelManager.instance.baseHeaders = mapOf("X-TEST" to "test")16FuelManager.instance.baseParams = listOf("test" to "test")17FuelManager.instance.baseHeaders = mapOf("X-TEST" to "test")18FuelManager.instance.baseParams = listOf("test" to "test")19FuelManager.instance.baseHeaders = mapOf("X-TEST" to "test")20FuelManager.instance.baseParams = listOf("test" to "test")21FuelManager.instance.baseHeaders = mapOf("X-TEST" to "test")

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.