app/src/main/java/net/nashlegend/sourcewall/request/interceptors/ProgressRequestBody.java

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

package net.nashlegend.sourcewall.request.interceptors;

import android.support.annotation.Nullable;

import net.nashlegend.sourcewall.request.RequestObject.RequestCallBack;

import java.io.IOException;

import okhttp3.MediaType;
import okhttp3.RequestBody;
import okio.Buffer;
import okio.BufferedSink;
import okio.ForwardingSink;
import okio.Okio;
import okio.Sink;

/**
 * Created by NashLegend on 16/6/29.
 */

public class ProgressRequestBody extends RequestBody {
    //实际的待包装请求体
    private final RequestBody requestBody;
    //进度回调接口
    @Nullable
    private final RequestCallBack callBack;
    //包装完成的BufferedSink
    private BufferedSink bufferedSink;

    /**
     * 构造函数，赋值
     *
     * @param requestBody 待包装的请求体
     * @param callBack
     */
    public ProgressRequestBody(RequestBody requestBody, @Nullable RequestCallBack callBack) {
        this.requestBody = requestBody;
        this.callBack = callBack;
    }

    /**
     * 重写调用实际的响应体的contentType
     *
     * @return MediaType
     */
    @Override
    public MediaType contentType() {
        return requestBody.contentType();
    }

    /**
     * 重写调用实际的响应体的contentLength
     *
     * @return contentLength
     * @throws IOException 异常
     */
    @Override
    public long contentLength() throws IOException {
        return requestBody.contentLength();
    }