From f1d8ec9fe7e20eeb5c1f4dbd2b48113dcafae341 Mon Sep 17 00:00:00 2001 From: liujingxing <327744707@qq.com> Date: Sat, 25 Sep 2021 19:40:41 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B3=A8=E9=87=8A=E4=B8=8A=E4=BC=A0/=E4=B8=8B?= =?UTF-8?q?=E8=BD=BD=E8=BF=9B=E5=BA=A6=E6=97=A5=E5=BF=97=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../kapt/debug/rxhttp/wrapper/param/ObservableParser.java | 4 ++-- .../src/main/java/com/rxhttp/compiler/ClassHelper.kt | 4 ++-- rxhttp/src/main/java/rxhttp/CallFactoryToAwait.kt | 2 +- .../java/rxhttp/wrapper/progress/ProgressRequestBody.java | 2 +- 4 files changed, 6 insertions(+), 6 deletions(-) diff --git a/app/build/generated/source/kapt/debug/rxhttp/wrapper/param/ObservableParser.java b/app/build/generated/source/kapt/debug/rxhttp/wrapper/param/ObservableParser.java index 558e18c8..234e7317 100644 --- a/app/build/generated/source/kapt/debug/rxhttp/wrapper/param/ObservableParser.java +++ b/app/build/generated/source/kapt/debug/rxhttp/wrapper/param/ObservableParser.java @@ -82,7 +82,7 @@ public void onProgress(int progress, long currentSize, long totalSize) { return; } try { - LogUtil.logDownProgress(progress, currentSize, totalSize); + //LogUtil.logDownProgress(progress, currentSize, totalSize); progressConsumer.accept(new Progress(progress, currentSize, totalSize)); } catch (Throwable t) { fail(t); @@ -194,7 +194,7 @@ public void onProgress(int progress, long currentSize, long totalSize) { if (done) { return; } - LogUtil.logDownProgress(progress, currentSize, totalSize); + //LogUtil.logDownProgress(progress, currentSize, totalSize); offer(new Progress(progress,currentSize,totalSize)); } diff --git a/rxhttp-compiler/src/main/java/com/rxhttp/compiler/ClassHelper.kt b/rxhttp-compiler/src/main/java/com/rxhttp/compiler/ClassHelper.kt index 0508cbc2..03325cc6 100644 --- a/rxhttp-compiler/src/main/java/com/rxhttp/compiler/ClassHelper.kt +++ b/rxhttp-compiler/src/main/java/com/rxhttp/compiler/ClassHelper.kt @@ -585,7 +585,7 @@ object ClassHelper { return; } try { - LogUtil.logDownProgress(progress, currentSize, totalSize); + //LogUtil.logDownProgress(progress, currentSize, totalSize); progressConsumer.accept(new Progress(progress, currentSize, totalSize)); } catch (Throwable t) { fail(t); @@ -697,7 +697,7 @@ object ClassHelper { if (done) { return; } - LogUtil.logDownProgress(progress, currentSize, totalSize); + //LogUtil.logDownProgress(progress, currentSize, totalSize); offer(new Progress(progress,currentSize,totalSize)); } diff --git a/rxhttp/src/main/java/rxhttp/CallFactoryToAwait.kt b/rxhttp/src/main/java/rxhttp/CallFactoryToAwait.kt index 5524be9c..880b90e7 100644 --- a/rxhttp/src/main/java/rxhttp/CallFactoryToAwait.kt +++ b/rxhttp/src/main/java/rxhttp/CallFactoryToAwait.kt @@ -53,7 +53,7 @@ fun CallFactory.toSyncDownload( val parser = SuspendStreamParser(osFactory) if (progressCallback != null) { parser.progress = { progress, currentSize, totalSize -> - LogUtil.logDownProgress(progress, currentSize, totalSize) + //LogUtil.logDownProgress(progress, currentSize, totalSize) val p = ProgressT(progress, currentSize, totalSize) progressCallback(p) } diff --git a/rxhttp/src/main/java/rxhttp/wrapper/progress/ProgressRequestBody.java b/rxhttp/src/main/java/rxhttp/wrapper/progress/ProgressRequestBody.java index 47ae4704..ae36a6ce 100644 --- a/rxhttp/src/main/java/rxhttp/wrapper/progress/ProgressRequestBody.java +++ b/rxhttp/src/main/java/rxhttp/wrapper/progress/ProgressRequestBody.java @@ -75,7 +75,7 @@ public void write(Buffer source, long byteCount) throws IOException { private void updateProgress(int progress, long currentSize, long totalSize) { if (callback == null) return; - LogUtil.logUpProgress(progress, currentSize, totalSize); + //LogUtil.logUpProgress(progress, currentSize, totalSize); callback.onProgress(progress, currentSize, totalSize); } }