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

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

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

package net.nashlegend.sourcewall.request.interceptors;

import android.support.annotation.Nullable;

import net.nashlegend.sourcewall.request.RequestObject;

import java.io.IOException;

import okhttp3.MediaType;
import okhttp3.ResponseBody;
import okio.Buffer;
import okio.BufferedSource;
import okio.ForwardingSource;
import okio.Okio;
import okio.Source;

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

public class ProgressResponseBody extends ResponseBody {
    //实际的待包装响应体
    private final ResponseBody responseBody;
    //进度回调接口
    @Nullable
    private final RequestObject.RequestCallBack callBack;
    //包装完成的BufferedSource
    private BufferedSource bufferedSource;

    /**
     * 构造函数，赋值
     *
     * @param responseBody 待包装的响应体
     * @param callBack
     */
    public ProgressResponseBody(ResponseBody responseBody, @Nullable RequestObject.RequestCallBack callBack) {
        this.responseBody = responseBody;
        this.callBack = callBack;
    }

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

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