How to use removeAllResponseInterceptors method of com.github.kittinunf.fuel.core.FuelManager class

...111    @Test112    fun testWithoutDefaultRedirectionInterceptor() {113        val manager = FuelManager()114        manager.addRequestInterceptor(cUrlLoggingRequestInterceptor())115        manager.removeAllResponseInterceptors()116        val (request, response, result) = manager.request(Method.GET,117                "https://httpbin.org/relative-redirect/3")118                .header(mapOf("User-Agent" to "Fuel"))119                .response()120        val (data, error) = result121        assertThat(request, notNullValue())122        assertThat(response, notNullValue())123        assertThat(error, nullValue())124        assertThat(data, notNullValue())125        assertThat(response.httpStatusCode, isEqualTo(HttpURLConnection.HTTP_MOVED_TEMP))126    }127    @Test128    fun testWithRedirectInterceptorRelative() {129        val manager = FuelManager()130        manager.addRequestInterceptor(cUrlLoggingRequestInterceptor())131        val (request, response, result) = manager.request(Method.GET,132                "https://httpbin.org/relative-redirect/3")133                .header(mapOf("User-Agent" to "Fuel"))134                .response()135        val (data, error) = result136        assertThat(request, notNullValue())137        assertThat(response, notNullValue())138        assertThat(error, nullValue())139        assertThat(data, notNullValue())140        assertThat(response.httpStatusCode, isEqualTo(HttpURLConnection.HTTP_OK))141    }142    @Test143    fun testWithRedirectInterceptorPreservesBaseHeaders() {144        val manager = FuelManager()145        manager.addRequestInterceptor(cUrlLoggingRequestInterceptor())146        manager.baseHeaders = mapOf("User-Agent" to "Fuel")147        val (request, response, result) = manager.request(Method.GET,148                "https://httpbin.org/redirect-to?url=/user-agent")149                .responseString(Charsets.UTF_8)150        val (data, error) = result151        assertThat(request, notNullValue())152        assertThat(response, notNullValue())153        assertThat(error, nullValue())154        assertThat(data, containsString("\"user-agent\": \"Fuel\""))155        assertThat(response.httpStatusCode, isEqualTo(HttpURLConnection.HTTP_OK))156    }157    @Test158    fun testNestedRedirectWithRedirectInterceptor() {159        val manager = FuelManager()160        manager.addRequestInterceptor(cUrlLoggingRequestInterceptor())161        val (request, response, result) = manager.request(Method.GET,162                "https://httpbin.org/redirect-to",163                listOf("url" to "https://httpbin.org/redirect-to?url=http://www.google.com"))164                .header(mapOf("User-Agent" to "Fuel"))165                .response()166        val (data, error) = result167        assertThat(request, notNullValue())168        assertThat(response, notNullValue())169        assertThat(error, nullValue())170        assertThat(data, notNullValue())171        assertThat(response.httpStatusCode, isEqualTo(HttpURLConnection.HTTP_OK))172    }173    @Test174    fun testHttpExceptionWithValidatorInterceptor() {175        val manager = FuelManager()176        manager.addResponseInterceptor(validatorResponseInterceptor(200..299))177        manager.addRequestInterceptor(cUrlLoggingRequestInterceptor())178        val (request, response, result) = manager.request(Method.GET,179                "http://httpbin.org/status/418").response()180        val (data, error) = result181        assertThat(request, notNullValue())182        assertThat(response, notNullValue())183        assertThat(error, notNullValue())184        assertThat(data, nullValue())185        assertThat(response.httpStatusCode, isEqualTo(418))186    }187    @Test188    fun testHttpExceptionWithRemoveInterceptors() {189        val manager = FuelManager()190        manager.removeAllResponseInterceptors()191        val (request, response, result) = manager.request(Method.GET,192                "http://httpbin.org/status/418").response()193        val (data, error) = result194        assertThat(request, notNullValue())195        assertThat(response, notNullValue())196        assertThat(error, nullValue())197        assertThat(data, notNullValue())198        assertThat(response.httpStatusCode, isEqualTo(418))199    }200}201 ...

...14object TelegraphApi {15	private var loginAccessToken: String? = null16	init {17		FuelManager.instance.basePath = "https://api.telegra.ph"18		FuelManager.instance.removeAllResponseInterceptors()19		FuelManager.instance.addResponseInterceptor {20			telegraphLoginInterceptor()21		}22		// Fix login23		FuelManager.instance.addResponseInterceptor {24			redirectResponseInterceptor(FuelManager.instance)25			it26		}27	}28	private fun callService(method: String, parameters: List<Pair<String, Any?>>, handler: (Request, Response, Result<FuelJson, FuelError>) -> Unit) {29		val requestObject = JSONObject()30		parameters.forEach {31			requestObject.put(it.first, it.second)32		}...

...24        }25    }26    // 为了确保重定向期间的cookie也能被获取，各个Interceptor的顺序就十分重要。27    // 必须保证获取cookie的Interceptor是位于重定向的Interceptor之前的。28    removeAllResponseInterceptors()29    // 获取cookie，存到默认DEFAULT_COOKIEJAR30    addResponseInterceptor { next ->31        { req, resp ->32            next(req, resp.saveCookie(DEFAULT_COOKIEJAR))33        }34    }35    // 处理重定向36    addResponseInterceptor(redirectResponseInterceptor(this))37    // 用于后端处理返回json中的errMsg字段，以保证错误消息能够被作为Exception的message。38    addResponseInterceptor(backendErrMsgHandler)39    // 设置超时40    timeoutInMillisecond = 500041    // 对于Fuel对象，也需要设置一下超时。在这里一并处理了。42    FuelManager.instance.timeoutInMillisecond = 5000...

...27    private val responseAnalyzers = HeadersAnalyzer(context.getAllowedHttpHeaders()) + StatusCodeAnalyzer(context.getAllowedStatusCodes()) + GroovyScriptAnalyzer(context.getGroovyScriptBody(), buildLogger)28    private lateinit var call: Request29    init {30        FuelManager.instance.client = HttpClient()31        FuelManager.instance.removeAllResponseInterceptors()32        FuelManager.instance.addResponseInterceptor(redirectResponseInterceptor())33    }34    override fun start() = prepareCall()35    override fun waitFor() = executeCall()36    override fun interrupt() = interruptCall()37    override fun isInterrupted() = isInterrupted38    override fun isFinished() = isInterrupted || normallyFinished39    private fun interruptCall() {40        call.interrupt {41            buildLogger.message("REST call to $endpoint interrupted")42        }43        isInterrupted = true44    }45    private fun prepareCall() {...

...42        var request: Request? = null43        var response: Response? = null44        var data: Any? = null45        var error: FuelError? = null46        manager.removeAllResponseInterceptors()47        manager.addResponseInterceptor(validatorResponseInterceptor(200..202))48        //this validate (200..202) which should fail with 20349        manager.request(Method.GET, "/status/$preDefinedStatusCode").responseString { req, res, result ->50            request = req51            response = res52            val (d, err) = result53            data = d54            error = err55        }56        assertThat(request, notNullValue())57        assertThat(response, notNullValue())58        assertThat(error, notNullValue())59        assertThat(data, nullValue())60        assertThat(response?.httpStatusCode, isEqualTo(preDefinedStatusCode))61    }62    @Test63    fun httpValidationWithCustomInvalidCase() {64        val preDefinedStatusCode = 41865        var request: Request? = null66        var response: Response? = null67        var data: Any? = null68        var error: FuelError? = null69        manager.removeAllResponseInterceptors()70        manager.addResponseInterceptor(validatorResponseInterceptor(400..419))71        manager.request(Method.GET, "/status/$preDefinedStatusCode").response { req, res, result ->72            request = req73            response = res74            when (result) {75                is Result.Failure -> {76                    error = result.getAs()77                }78                is Result.Success -> {79                    data = result.getAs()80                }81            }82        }83        assertThat(request, notNullValue())...

...21class FuelHttpClient(private val metaMap: MetaMap) : HttpClient {22    private val log = logger {}23    init {24        // get rid of: redirectResponseInterceptor(this), validatorResponseInterceptor(200..299)25        FuelManager.instance.removeAllResponseInterceptors()26    }27    private fun String.httpAny(method: HttpMethod4k) =28        when (method) {29            HttpMethod4k.GET -> { httpGet() }30            HttpMethod4k.POST -> { httpPost() }31            HttpMethod4k.PUT -> { httpPut() }32            HttpMethod4k.DELETE -> { httpDelete() }33            HttpMethod4k.PATCH -> { httpPost() } // fuel hack, as it doesnt support patch34        }35    override fun execute(request4k: Request4k): Response4k {36        log.debug { "execute($request4k) ... $metaMap" }37        val (_, response, result) = request4k.url.httpAny(request4k.method)38                .apply {39                    header(request4k.headers)...

...32        logger.info("Application initialization...")33        initFuel()34    }35    private fun initFuel() {36        FuelManager.instance.removeAllResponseInterceptors()37        FuelManager.instance.addResponseInterceptor(validatorResponseInterceptor(IntRange(100, 599)))38    }39    private fun setWebHook() {40        javaClass.classLoader.getResourceAsStream("${Constants.RESOURCES_PATH}/$CERT_FILE_NAME").use {41            val formBuilder = FormBuilder()42            formBuilder.addText("$PARAMETER_URL", "${Constants.BASE_API_URL}/${Endpoints.UPDATES}")43            formBuilder.addText("$PARAMETER_MAX_CONNECTIONS", Constants.MAX_CONNECTIONS.toString())44            formBuilder.addFile("$PARAMETER_CERTIFICATE", it, CERT_FILE_NAME)45            try {46                val responseJson = "${Constants.TELEGRAM_BASE_API_URL}/$SET_WEBHOOK_ENDPOINT"47                        .httpPost()48                        .header(Pair(HttpHeaderNames.CONTENT_TYPE,49                                "${MediaType.MULTIPART_FORM_DATA}; boundary=${formBuilder.boundary}"))50                        .body(formBuilder.toByteArray())...

...8val CookiedFuel = FuelManager().apply {9    addRequestInterceptor { next -> {req ->10        next(req.enableCookie(DEFAULT_COOKIEJAR))11    } }12    removeAllResponseInterceptors()13    addResponseInterceptor { next -> {req, resp ->14        next(req, resp.saveCookie(DEFAULT_COOKIEJAR))15    } }16    addResponseInterceptor(redirectResponseInterceptor(this))17}18private val SAVECOOKIE_KV_PATTERN = Pattern.compile("^(.+)=(.*)$")19private val SAVECOOKIE_PATH_PATTERN = Pattern.compile("^Path=(.*)$", Pattern.CASE_INSENSITIVE)20fun Response.saveCookie(cookieJar: CookieJar): Response {21    val domain = this.url.host22    val SCs = this[Headers.SET_COOKIE]23    for (SC in SCs) {24        val items = SC.split("; ")25        val main = items[0]26        val remainItems = items.drop(1)...

1FuelManager.instance.removeAllResponseInterceptors()2FuelManager.instance.removeAllResponseInterceptors()3FuelManager.instance.removeAllResponseInterceptors()4FuelManager.instance.removeAllResponseInterceptors()5FuelManager.instance.removeAllResponseInterceptors()6FuelManager.instance.removeAllResponseInterceptors()7FuelManager.instance.removeAllResponseInterceptors()8FuelManager.instance.removeAllResponseInterceptors()9FuelManager.instance.removeAllResponseInterceptors()10FuelManager.instance.removeAllResponseInterceptors()11FuelManager.instance.removeAllResponseInterceptors()12FuelManager.instance.removeAllResponseInterceptors()13FuelManager.instance.removeAllResponseInterceptors()14FuelManager.instance.removeAllResponseInterceptors()15FuelManager.instance.removeAllResponseInterceptors()

1FuelManager.instance.removeAllResponseInterceptors()2FuelManager.instance.removeAllRequestInterceptors()3FuelManager.instance.removeResponseInterceptor(interceptor)4FuelManager.instance.removeRequestInterceptor(interceptor)5FuelManager.instance.addResponseInterceptor(interceptor)6FuelManager.instance.addRequestInterceptor(interceptor)7FuelManager.instance.addResponseInterceptor(interceptor)8FuelManager.instance.addRequestInterceptor(interceptor)9FuelManager.instance.removeAllResponseInterceptors()10FuelManager.instance.removeAllRequestInterceptors()11FuelManager.instance.removeResponseInterceptor(interceptor)12FuelManager.instance.removeRequestInterceptor(interceptor)13FuelManager.instance.addResponseInterceptor(interceptor)14FuelManager.instance.addRequestInterceptor(interceptor)15FuelManager.instance.addResponseInterceptor(interceptor)

1FuelManager.instance.removeAllResponseInterceptors()2FuelManager.instance.removeAllRequestInterceptors()3FuelManager.instance.removeAllHeaders()4FuelManager.instance.removeAllParameters()5FuelManager.instance.removeAllCookies()6FuelManager.instance.removeAllQueryParameters()7FuelManager.instance.removeAllResponseInterceptors()8FuelManager.instance.removeAllRequestInterceptors()9FuelManager.instance.removeAllHeaders()10FuelManager.instance.removeAllParameters()11FuelManager.instance.removeAllCookies()12FuelManager.instance.removeAllQueryParameters()13FuelManager.instance.removeAllResponseInterceptors()14FuelManager.instance.removeAllRequestInterceptors()15FuelManager.instance.removeAllHeaders()16FuelManager.instance.removeAllParameters()17FuelManager.instance.removeAllCookies()

1val manager = FuelManager()2manager.removeAllResponseInterceptors()3val manager = FuelManager()4manager.addResponseInterceptor { next -> { req, res ->5next(req, res)6}7}8val manager = FuelManager()9manager.removeAllRequestInterceptors()10val manager = FuelManager()11manager.addRequestInterceptor { next -> { req ->12next(req)13}14}15val manager = FuelManager()16manager.removeAllRequestInterceptors()17val manager = FuelManager()18manager.addRequestInterceptor { next -> { req ->19next(req)20}21}22val manager = FuelManager()23manager.removeAllRequestInterceptors()24val manager = FuelManager()25manager.addRequestInterceptor { next -> { req ->26next(req)27}28}29val manager = FuelManager()30manager.removeAllRequestInterceptors()31val manager = FuelManager()32manager.addRequestInterceptor { next -> { req ->33next(req)34}35}36val manager = FuelManager()37manager.removeAllRequestInterceptors()38val manager = FuelManager()39manager.addRequestInterceptor { next -> { req ->40next(req