Add setRefreshTime control refresh time

Author: JessYanCoding

progress/src/main/java/me/jessyan/progressmanager/ProgressManager.java

@@ -9,6 +9,7 @@
 import java.util.Map;
 import java.util.WeakHashMap;
 
+import me.jessyan.progressmanager.body.ProgressInfo;
 import me.jessyan.progressmanager.body.ProgressRequestBody;
 import me.jessyan.progressmanager.body.ProgressResponseBody;
 import okhttp3.Interceptor;
@@ -32,11 +33,13 @@ public final class ProgressManager {
  private final Map<String, List<ProgressListener>> mResponseListeners = new WeakHashMap<>();
  private final Handler mHandler; //所有监听器在 Handler 中被执行,所以可以保证所有监听器在主线程中被执行
  private final Interceptor mInterceptor;
+ private int mRefreshTime = DEFAULT_REFRESH_TIME;
 
  private static volatile ProgressManager mProgressManager;
 
  public static final boolean DEPENDENCY_OKHTTP;
- public static int REFRESH_TIME = 200; //回调刷新时间(单位ms),避免高频率调用
+ public static final int DEFAULT_REFRESH_TIME = 150; //回调刷新时间(单位ms),避免高频率调用
+
 
  static {
  boolean hasDependency;
@@ -75,6 +78,16 @@ public static ProgressManager getInstance() {
  return mProgressManager;
  }
 
+
+ /**
+ * 设置 {@link ProgressListener#onProgress(ProgressInfo)} 每次被调用的间隔时间,单位毫秒
+ *
+ * @param refreshTime
+ */
+ public void setRefreshTime(int refreshTime) {
+ this.mRefreshTime = refreshTime;
+ }
+
  /**
  * 将需要被监听上传进度的 Url 注册到管理器,此操作请在页面初始化时进行,切勿多次注册同一个(内容相同)监听器
  *
@@ -152,7 +165,7 @@ public Request wrapRequestBody(Request request) {
  if (mRequestListeners.containsKey(key)) {
  List<ProgressListener> listeners = mRequestListeners.get(key);
  return request.newBuilder()
- .method(request.method(), new ProgressRequestBody(mHandler, request.body(), listeners))
+ .method(request.method(), new ProgressRequestBody(mHandler, request.body(), listeners, mRefreshTime))
  .build();
  }
  return request;
@@ -173,7 +186,7 @@ public Response wrapResponseBody(Response response) {
  if (mResponseListeners.containsKey(key)) {
  List<ProgressListener> listeners = mResponseListeners.get(key);
  return response.newBuilder()
- .body(new ProgressResponseBody(mHandler, response.body(), listeners))
+ .body(new ProgressResponseBody(mHandler, response.body(), listeners, mRefreshTime))
  .build();
  }
  return response;

progress/src/main/java/me/jessyan/progressmanager/body/ProgressRequestBody.java

@@ -15,8 +15,6 @@
 import okio.Okio;
 import okio.Sink;
 
-import static me.jessyan.progressmanager.ProgressManager.REFRESH_TIME;
-
 /**
  * 继承于{@link RequestBody},通过此类获取 Okhttp 上传的二进制数据
  * Created by jess on 02/06/2017 18:05
@@ -26,16 +24,18 @@
 public class ProgressRequestBody extends RequestBody {
 
  protected Handler mHandler;
+ protected int mRefreshTime;
  protected final RequestBody mDelegate;
  protected final ProgressListener[] mListeners;
  protected final ProgressInfo mProgressInfo;
  private BufferedSink mBufferedSink;
 
 
- public ProgressRequestBody(Handler handler, RequestBody delegate, List<ProgressListener> listeners) {
+ public ProgressRequestBody(Handler handler, RequestBody delegate, List<ProgressListener> listeners, int refreshTime) {
  this.mDelegate = delegate;
  this.mListeners = listeners.toArray(new ProgressListener[listeners.size()]);
  this.mHandler = handler;
+ this.mRefreshTime = refreshTime;
  this.mProgressInfo = new ProgressInfo(System.currentTimeMillis());
  }
 
@@ -98,7 +98,7 @@ public void write(Buffer source, long byteCount) throws IOException {
  tempSize += byteCount;
  if (mListeners != null) {
  long curTime = SystemClock.elapsedRealtime();
- if (curTime - lastRefreshTime >= REFRESH_TIME || totalBytesRead == mProgressInfo.getContentLength()) {
+ if (curTime - lastRefreshTime >= mRefreshTime || totalBytesRead == mProgressInfo.getContentLength()) {
  final long finalTempSize = tempSize;
  final long finalTotalBytesRead = totalBytesRead;
  final long finalIntervalTime = curTime - lastRefreshTime;

progress/src/main/java/me/jessyan/progressmanager/body/ProgressResponseBody.java

@@ -15,8 +15,6 @@
 import okio.Okio;
 import okio.Source;
 
-import static me.jessyan.progressmanager.ProgressManager.REFRESH_TIME;
-
 /**
  * 继承于{@link ResponseBody},通过此类获取 Okhttp 下载的二进制数据
  * Created by jess on 02/06/2017 18:25
@@ -26,15 +24,17 @@
 public class ProgressResponseBody extends ResponseBody {
 
  protected Handler mHandler;
+ protected int mRefreshTime;
  protected final ResponseBody mDelegate;
  protected final ProgressListener[] mListeners;
  protected final ProgressInfo mProgressInfo;
  private BufferedSource mBufferedSource;
 
- public ProgressResponseBody(Handler handler, ResponseBody responseBody, List<ProgressListener> listeners) {
+ public ProgressResponseBody(Handler handler, ResponseBody responseBody, List<ProgressListener> listeners, int refreshTime) {
  this.mDelegate = responseBody;
  this.mListeners = listeners.toArray(new ProgressListener[listeners.size()]);
  this.mHandler = handler;
+ this.mRefreshTime = refreshTime;
  this.mProgressInfo = new ProgressInfo(System.currentTimeMillis());
  }
 
@@ -82,7 +82,7 @@ public long read(Buffer sink, long byteCount) throws IOException {
  tempSize += bytesRead != -1 ? bytesRead : 0;
  if (mListeners != null) {
  long curTime = SystemClock.elapsedRealtime();
- if (curTime - lastRefreshTime >= REFRESH_TIME || bytesRead == -1 || totalBytesRead == mProgressInfo.getContentLength()) {
+ if (curTime - lastRefreshTime >= mRefreshTime || bytesRead == -1 || totalBytesRead == mProgressInfo.getContentLength()) {
  final long finalBytesRead = bytesRead;
  final long finalTempSize = tempSize;
  final long finalTotalBytesRead = totalBytesRead;