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

Copied to Clipboard!

How to use progress method of com.github.kittinunf.fuel.core.requests.DownloadRequest class

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

Request.kt

Source:Request.kt

...19    /**20     * Add a [ProgressCallback] tracking the [Body] of the [Request]21     *22     * @see body23     * @see com.github.kittinunf.fuel.core.requests.UploadRequest.progress24     *25     * @return self26     */27    fun requestProgress(handler: ProgressCallback): Request28    /**29     * Add a [ProgressCallback] tracking the [Body] of the [Response]30     *31     * @see com.github.kittinunf.fuel.core.requests.DownloadRequest.progress32     *33     * @return self34     */35    fun responseProgress(handler: ProgressCallback): Request36    /**37     * Overwrite the [Request] [timeout] in milliseconds38     *39     * @note [Client] must implement this behaviour40     * @note the default client sets [java.net.HttpURLConnection.setConnectTimeout]41     *42     * @param timeout [Int] timeout in milliseconds43     * @return self44     */45    fun timeout(timeout: Int): Request...

DefaultRequest.kt

Source:DefaultRequest.kt

...267    /**268     * Add a [ProgressCallback] tracking the [Body] of the [Request]269     *270     * @see body271     * @see com.github.kittinunf.fuel.core.requests.UploadRequest.progress272     *273     * @return self274     */275    override fun requestProgress(handler: ProgressCallback): Request {276        executionOptions.requestProgress += handler277        return request278    }279    /**280     * Add a [ProgressCallback] tracking the [Body] of the [com.github.kittinunf.fuel.core.Response]281     *282     * @see com.github.kittinunf.fuel.core.requests.DownloadRequest.progress283     *284     * @return self285     */286    override fun responseProgress(handler: ProgressCallback): Request {287        executionOptions.responseProgress += handler288        return request289    }290    /**291     * Add a [InterruptCallback] to the [RequestExecutionOptions]292     *293     * @see RequestExecutionOptions.interruptCallbacks294     *295     * @return self296     */...

FuelManager.kt

Source:FuelManager.kt

...27    var proxy: Proxy? = null28    var basePath: String? = null29    var timeoutInMillisecond: Int = 15_00030    var timeoutReadInMillisecond: Int = timeoutInMillisecond31    var progressBufferSize: Int = DEFAULT_BUFFER_SIZE32    var hook: Hook = DefaultHook()33    var baseHeaders: Map<String, String>? = null34    var baseParams: Parameters = emptyList()35    var keystore: KeyStore? = null36    var socketFactory: SSLSocketFactory by readWriteLazy {37        keystore?.let {38            val trustFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm())39            trustFactory.init(it)40            val sslContext = SSLContext.getInstance("SSL")41            sslContext.init(null, trustFactory.trustManagers, null)42            sslContext.socketFactory43        } ?: HttpsURLConnection.getDefaultSSLSocketFactory()44    }45    var hostnameVerifier: HostnameVerifier by readWriteLazy {46        HttpsURLConnection.getDefaultHostnameVerifier()47    }48    // background executionOptions49    var executorService: ExecutorService by readWriteLazy {50        Executors.newCachedThreadPool { command ->51            Thread(command).also { thread ->52                thread.priority = Thread.NORM_PRIORITY53                thread.isDaemon = true54            }55        }56    }57    private val requestInterceptors: MutableList<FoldableRequestInterceptor> =58            mutableListOf(ParameterEncoder)59    private val responseInterceptors: MutableList<FoldableResponseInterceptor> =60            mutableListOf(redirectResponseInterceptor(this))61    // callback executionOptions62    var callbackExecutor: Executor by readWriteLazy { createEnvironment().callbackExecutor }63    var forceMethods: Boolean = false64    /**65     * Make a request using [method] to [path] with [parameters]66     *67     * @see FuelManager.instance68     * @see FuelManager.applyOptions69     *70     * @param method [Method] the HTTP method to make the request with71     * @param path [String] the absolute url or relative to [FuelManager.instance] basePath72     * @param parameters [Parameters?] list of parameters73     *74     * @return [Request] the request75     */76    override fun request(method: Method, path: String, parameters: Parameters?): Request {77        val request = request(Encoding(78            httpMethod = method,79            urlString = path,80            baseUrlString = basePath,81            parameters = if (parameters == null) baseParams else baseParams + parameters82        ).request)83        return applyOptions(request)84    }85    /**86     * Make a request using [method] to [convertible]'s path with [parameters]87     *88     * @see FuelManager.instance89     * @see RequestFactory(Method, String, Parameters?)90     *91     * @param method [Method] the HTTP method to make the request with92     * @param convertible [PathStringConvertible]93     * @param parameters [Parameters?] list of parameters94     *95     * @return [Request] the request96     */97    override fun request(method: Method, convertible: PathStringConvertible, parameters: Parameters?): Request =98        request(method, convertible.path, parameters)99    /**100     * Make a request using from [convertible]101     *102     * @param convertible [RequestConvertible] the instance that can be turned into a [Request]103     * @return [Request] the request104     */105    override fun request(convertible: RequestConvertible): Request = applyOptions(convertible.request)106    /**107     * Create a [method] [Request] to [path] with [parameters], which can download to a file108     *109     * @param path [String] the absolute or relative to [FuelManager.instance]' base-path path110     * @param method [Method] the method to download with, defaults to [Method.GET]111     * @param parameters [Parameters] the optional parameters112     * @return [DownloadRequest] the request (extended for download)113     */114    override fun download(path: String, method: Method, parameters: Parameters?): DownloadRequest {115        val request = Encoding(116            httpMethod = method,117            urlString = path,118            baseUrlString = basePath,119            parameters = if (parameters == null) baseParams else baseParams + parameters120        ).request121        return applyOptions(request).download()122    }123    /**124     * Create a [method] [Request] to [path] with [parameters], which can upload blobs and Data Parts125     *126     * @param path [String] the absolute or relative to [FuelManager.instance]' base-path path127     * @param method [Method] the method to upload with, defaults to [Method.POST]128     * @param parameters [Parameters] the optional parameters129     * @return [UploadRequest] the request (extended for upload)130     */131    override fun upload(path: String, method: Method, parameters: Parameters?): UploadRequest {132        val request = Encoding(133            httpMethod = method,134            urlString = path,135            baseUrlString = basePath,136            parameters = if (parameters == null) baseParams else baseParams + parameters137        ).request138        return applyOptions(request).upload()139    }140    fun addRequestInterceptor(interceptor: FoldableRequestInterceptor): FuelManager {141        requestInterceptors += interceptor142        return this143    }144    fun addResponseInterceptor(interceptor: FoldableResponseInterceptor): FuelManager {145        responseInterceptors += interceptor146        return this147    }148    fun removeRequestInterceptor(interceptor: FoldableRequestInterceptor): FuelManager {149        requestInterceptors -= interceptor150        return this151    }152    fun removeResponseInterceptor(interceptor: FoldableResponseInterceptor): FuelManager {153        responseInterceptors -= interceptor154        return this155    }156    fun removeAllRequestInterceptors(): FuelManager {157        requestInterceptors.clear()158        return this159    }160    fun removeAllResponseInterceptors(): FuelManager {161        responseInterceptors.clear()162        return this163    }164    private fun applyOptions(request: Request): Request {165        // Sets base headers ONLY if they are not set166        val unsetBaseHeaders = request.headers.keys.fold(Headers.from(baseHeaders.orEmpty())) {167            result, it -> result.remove(it); result168        }169        return request.header(unsetBaseHeaders).apply {170            executionOptions = RequestExecutionOptions(171                client = client,172                socketFactory = socketFactory,173                hostnameVerifier = hostnameVerifier,174                callbackExecutor = callbackExecutor,175                requestTransformer = requestInterceptors.foldRight({ r: Request -> r }) { f, acc -> f(acc) },176                responseTransformer = responseInterceptors.foldRight({ _: Request, res: Response -> res }) { f, acc -> f(acc) },177                executorService = executorService178            ).also { executor ->179                executor.timeoutInMillisecond = timeoutInMillisecond180                executor.timeoutReadInMillisecond = timeoutReadInMillisecond181                executor.forceMethods = forceMethods182            }183        }184    }185    companion object {186        // manager187        var instance by readWriteLazy { FuelManager() }188        val progressBufferSize: Int get() = instance.progressBufferSize189    }190    /**191     * Create a [Method.GET] [Request] to [path] with [parameters]192     *193     * @param path [String] the absolute or relative to [FuelManager.instance]' base-path path194     * @param parameters [Parameters] the optional parameters195     * @return [Request] the request196     */197    override fun get(path: String, parameters: Parameters?): Request =198        request(Method.GET, path, parameters)199    /**200     * Create a [Method.GET] [Request] to [PathStringConvertible.path] with [parameters]201     *202     * @param convertible [PathStringConvertible] the absolute or relative to [FuelManager.instance]' base-path path...

DownLoadAppService.kt

Source:DownLoadAppService.kt

...133            Fuel.download("http://manage.wenyuriverpark.com:8082/apk/ar.apk")134        //  æå»ºFileOutputStreamå¯¹è±¡,æä»¶ä¸åå¨ä¼èªå¨æ°å»º135        compositeDisposable.add(downloadRequest.fileDestination { _, _ ->136            downloadFile137        }.progress { readBytes, totalBytes ->138            if (totalBytes != -1L) {139                //  allow 2 updates/second max - more than 10/second will be blocked140                if (System.currentTimeMillis() - lastUpdate > 600) {141                    lastUpdate = System.currentTimeMillis()142                    Logger.i("$readBytes/$totalBytes")143                    val progress = readBytes.toFloat() / totalBytes.toFloat() * 100144                    updateProgress(progress)145                    downloadFinishFlag = false146                }147            } else {148                //æä»¶éè¯¯149                runOnUiThread {150                    MVVMBaseApplication.appContext.showToast("æä»¶ç ´æï¼ï¼")151                }152                downloadFinishFlag = true153            }154        }.rxResponse()155            .compose(RxScheduler.applySingleScheduler())156            .subscribe({157                notifyManager.cancel(NOTIFY_ID_DOWNLOAD)158                installApp()159                downloadFinishFlag = true160            }, {161                Logger.i(it.message.toString())162                downloadFinishFlag = false163            })164        )165    }166    private fun updateProgress(progress: Float) {167        customRemoteViews.setProgressBar(168            R.id.notify_progress,169            100,170            ceil(progress).toInt(),171            false172        )173        customRemoteViews.setTextViewText(174            R.id.tvProgress,175            "${ceil(progress).toInt()}%"176        )177        notifyManager.notify(NOTIFY_ID_DOWNLOAD, notification)178    }179    private fun installApp() {180        if (downloadFile.isFile) {181            // éè¿Intentå®è£APKæä»¶182            val intents = Intent(Intent.ACTION_INSTALL_PACKAGE)183            val uri: Uri = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.N) {184                intents.addFlags(FLAG_GRANT_READ_URI_PERMISSION)185                FileProvider.getUriForFile(this, fileProviderAuth, downloadFile)186            } else {187                Uri.fromFile(downloadFile)188            }189            grantUriPermission(packageName, uri, FLAG_GRANT_READ_URI_PERMISSION)...

DownloadRequest.kt

Source:DownloadRequest.kt

...47    fun streamDestination(destination: StreamDestinationCallback): DownloadRequest {48        destinationCallback = destination49        return request50    }51    fun progress(progress: ProgressCallback) = responseProgress(progress)52    private fun transformResponse(request: Request, response: Response): Response {53        val (output, inputCallback) = this.destinationCallback(response, request)54        output.use { outputStream ->55            response.body.toStream().use { inputStream ->56                inputStream.copyTo(out = outputStream)57            }58        }59        // This allows the stream to be written to disk first and then return the written file.60        // We can not calculate the length here because inputCallback might not return the actual output as we write it.61        return response.copy(body = DefaultBody.from(inputCallback, null))62    }63    companion object {64        val FEATURE: String = DownloadRequest::class.java.canonicalName65        fun enableFor(request: Request) = request.enabledFeatures...

progress

Using AI Code Generation

1DownloadRequest. download ( url , destination ). progress { readBytes , totalBytes ->2}3UploadRequest. upload ( url , destination ). progress { readBytes , totalBytes ->4}5Request. request ( Method . GET , url ). progress { readBytes , totalBytes ->6}7Request. request ( Method . POST , url ). progress { readBytes , totalBytes ->8}9Request. request ( Method . PUT , url ). progress { readBytes , totalBytes ->10}11Request. request ( Method . DELETE , url ). progress { readBytes , totalBytes ->12}13Request. request ( Method . PATCH , url ). progress { readBytes , totalBytes ->14}15Request. request ( Method . HEAD , url ). progress { readBytes , totalBytes ->16}17Request. request ( Method . OPTIONS , url ). progress { readBytes , totalBytes ->

progress

Using AI Code Generation

1val progressHandler = { readBytes: Long, totalBytes: Long ->2Log.d("download", "readBytes = $readBytes, totalBytes = $totalBytes")3}4Fuel.download(url)5.progress(progressHandler)6.destination { response, url ->7File.createTempFile("download", "tmp")8}9.response { request, response, result ->10Log.d("download", "request = ${request.url}")11}12.join()

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.