1. 新增问题和删除修改功能（调试中） 2. 轨迹记录功能开放为所有类型的场景都记录

riku

2020-08-28 e3864138492d1d3280710a1ba7162d9dd7542404

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
package cn.flightfeather.thirdapp.common.net
 
import cn.flightfeather.thirdapp.common.net.NetWorkProgressListener
import okhttp3.MediaType
import okhttp3.RequestBody
import okio.*
 
/**
 * @author riku
 * Date: 2020/4/24
 * 带进度回调的RequestBody
 */
class ProgressRequestBody(
    private val mRequestBody: RequestBody?,
    private val netWorkProgressListener: NetWorkProgressListener
) : RequestBody() {
 
    override fun contentType(): MediaType? = mRequestBody?.contentType()
 
    override fun contentLength(): Long = mRequestBody?.contentLength() ?: super.contentLength()
 
    override fun writeTo(sink: BufferedSink) {
        val progressSink = ProgressSink(sink)
        val newSink = Okio.buffer(progressSink)
        mRequestBody?.writeTo(newSink)
        newSink.flush()
    }
 
    inner class ProgressSink(delegate: Sink) : ForwardingSink(delegate) {
        private var bytesWritten = 0L
 
        override fun write(source: Buffer, byteCount: Long) {
            super.write(source, byteCount)
            bytesWritten += byteCount
            netWorkProgressListener.onProgress(bytesWritten, contentLength())
        }
    }
}