From 055ce8d5906cc83557d68aad8bd6372da0f10f39 Mon Sep 17 00:00:00 2001 From: lh <642404044@qq.com> Date: Thu, 6 Jul 2017 17:37:57 +0800 Subject: [PATCH 1/3] upload test --- app/src/main/AndroidManifest.xml | 1 + 1 file changed, 1 insertion(+) diff --git a/app/src/main/AndroidManifest.xml b/app/src/main/AndroidManifest.xml index 9b4c4f7..0d04bd1 100644 --- a/app/src/main/AndroidManifest.xml +++ b/app/src/main/AndroidManifest.xml @@ -4,6 +4,7 @@ + Date: Thu, 6 Jul 2017 18:13:03 +0800 Subject: [PATCH 2/3] =?UTF-8?q?=E5=AD=A6=E4=B9=A0=E5=88=B0CompositeDisposa?= =?UTF-8?q?ble=E8=BF=99=E9=87=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../android/samples/ui/OperatorsActivity.java | 3 ++ .../android/samples/ui/SelectionActivity.java | 3 ++ .../ui/networking/NetworkingActivity.java | 28 +++++++++---------- .../AsyncSubjectExampleActivity.java | 16 +++++------ .../BehaviorSubjectExampleActivity.java | 16 +++++------ .../ui/operators/BufferExampleActivity.java | 10 +++---- .../CompletableObserverExampleActivity.java | 6 ++-- .../ui/operators/ConcatExampleActivity.java | 8 +++--- .../ui/operators/DebounceExampleActivity.java | 10 +++---- .../ui/operators/DeferExampleActivity.java | 8 +++--- .../ui/operators/DelayExampleActivity.java | 8 +++--- .../operators/DisposableExampleActivity.java | 9 ++++-- .../ui/operators/DistinctExampleActivity.java | 8 +++--- .../ui/operators/FilterExampleActivity.java | 10 +++---- .../ui/operators/FlowableExampleActivity.java | 6 ++-- .../ui/operators/IntervalExampleActivity.java | 6 ++-- .../LastOperatorExampleActivity.java | 6 ++-- .../ui/operators/MapExampleActivity.java | 8 +++--- .../ui/operators/MergeExampleActivity.java | 8 +++--- .../PublishSubjectExampleActivity.java | 16 +++++------ .../ui/operators/ReduceExampleActivity.java | 8 +++--- .../ui/operators/ReplayExampleActivity.java | 16 +++++------ .../ReplaySubjectExampleActivity.java | 16 +++++------ .../ui/operators/ScanExampleActivity.java | 8 +++--- .../ui/operators/SimpleExampleActivity.java | 10 +++---- .../SingleObserverExampleActivity.java | 6 ++-- .../ui/operators/SkipExampleActivity.java | 8 +++--- .../ui/operators/TakeExampleActivity.java | 8 +++--- .../ThrottleFirstExampleActivity.java | 10 +++---- .../ThrottleLastExampleActivity.java | 10 +++---- .../ui/operators/TimerExampleActivity.java | 8 +++--- .../ui/operators/WindowExampleActivity.java | 2 +- .../ui/operators/ZipExampleActivity.java | 8 +++--- .../rxjava2/android/samples/utils/Utils.java | 10 +++---- 34 files changed, 165 insertions(+), 156 deletions(-) diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/OperatorsActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/OperatorsActivity.java index 63df8a2..cf060bd 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/OperatorsActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/OperatorsActivity.java @@ -37,6 +37,9 @@ import com.rxjava2.android.samples.ui.operators.WindowExampleActivity; import com.rxjava2.android.samples.ui.operators.ZipExampleActivity; +/** + * 学习各种各样的操作符 + */ public class OperatorsActivity extends AppCompatActivity { @Override diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/SelectionActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/SelectionActivity.java index e431b0a..8bdd4c3 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/SelectionActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/SelectionActivity.java @@ -12,6 +12,9 @@ import com.rxjava2.android.samples.ui.pagination.PaginationActivity; import com.rxjava2.android.samples.ui.rxbus.RxBusActivity; +/** + * 选择页面 + */ public class SelectionActivity extends AppCompatActivity { @Override diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/networking/NetworkingActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/networking/NetworkingActivity.java index f651870..593e01c 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/networking/NetworkingActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/networking/NetworkingActivity.java @@ -67,7 +67,7 @@ public void onSubscribe(Disposable d) { @Override public void onNext(User user) { - Log.d(TAG, "user : " + user.toString()); + Log.i(TAG, "user : " + user.toString()); } @Override @@ -77,7 +77,7 @@ public void onError(Throwable e) { @Override public void onComplete() { - Log.d(TAG, "onComplete"); + Log.i(TAG, "onComplete"); } }); } @@ -132,9 +132,9 @@ public void onSubscribe(Disposable d) { @Override public void onNext(List users) { // do anything with user who loves both - Log.d(TAG, "userList size : " + users.size()); + Log.i(TAG, "userList size : " + users.size()); for (User user : users) { - Log.d(TAG, "user : " + user.toString()); + Log.i(TAG, "user : " + user.toString()); } } @@ -145,7 +145,7 @@ public void onError(Throwable e) { @Override public void onComplete() { - Log.d(TAG, "onComplete"); + Log.i(TAG, "onComplete"); } }); } @@ -205,7 +205,7 @@ public void onSubscribe(Disposable d) { @Override public void onNext(User user) { // only the user who is following me comes here one by one - Log.d(TAG, "user : " + user.toString()); + Log.i(TAG, "user : " + user.toString()); } @Override @@ -215,7 +215,7 @@ public void onError(Throwable e) { @Override public void onComplete() { - Log.d(TAG, "onComplete"); + Log.i(TAG, "onComplete"); } }); } @@ -245,7 +245,7 @@ public void onSubscribe(Disposable d) { @Override public void onNext(User user) { // // only four user comes here one by one - Log.d(TAG, "user : " + user.toString()); + Log.i(TAG, "user : " + user.toString()); } @Override @@ -255,7 +255,7 @@ public void onError(Throwable e) { @Override public void onComplete() { - Log.d(TAG, "onComplete"); + Log.i(TAG, "onComplete"); } }); } @@ -298,12 +298,12 @@ public void onError(Throwable e) { @Override public void onNext(UserDetail userDetail) { // do anything with userDetail - Log.d(TAG, "userDetail : " + userDetail.toString()); + Log.i(TAG, "userDetail : " + userDetail.toString()); } @Override public void onComplete() { - Log.d(TAG, "onComplete"); + Log.i(TAG, "onComplete"); } }); } @@ -359,7 +359,7 @@ public Pair apply(UserDetail userDetail, User user) throws Exc @Override public void onComplete() { // do something onCompleted - Log.d(TAG, "onComplete"); + Log.i(TAG, "onComplete"); } @Override @@ -378,8 +378,8 @@ public void onNext(Pair pair) { // here we are getting the userDetail for the corresponding user one by one UserDetail userDetail = pair.first; User user = pair.second; - Log.d(TAG, "user : " + user.toString()); - Log.d(TAG, "userDetail : " + userDetail.toString()); + Log.i(TAG, "user : " + user.toString()); + Log.i(TAG, "userDetail : " + userDetail.toString()); } }); } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/AsyncSubjectExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/AsyncSubjectExampleActivity.java index 501bc63..8860a16 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/AsyncSubjectExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/AsyncSubjectExampleActivity.java @@ -69,28 +69,28 @@ private Observer getFirstObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " First onSubscribe : " + d.isDisposed()); + Log.i(TAG, " First onSubscribe : " + d.isDisposed()); } @Override public void onNext(Integer value) { textView.append(" First onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onNext value : " + value); + Log.i(TAG, " First onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" First onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onError : " + e.getMessage()); + Log.i(TAG, " First onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" First onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onComplete"); + Log.i(TAG, " First onComplete"); } }; } @@ -101,7 +101,7 @@ private Observer getSecondObserver() { @Override public void onSubscribe(Disposable d) { textView.append(" Second onSubscribe : isDisposed :" + d.isDisposed()); - Log.d(TAG, " Second onSubscribe : " + d.isDisposed()); + Log.i(TAG, " Second onSubscribe : " + d.isDisposed()); textView.append(AppConstant.LINE_SEPARATOR); } @@ -109,21 +109,21 @@ public void onSubscribe(Disposable d) { public void onNext(Integer value) { textView.append(" Second onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onNext value : " + value); + Log.i(TAG, " Second onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" Second onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onError : " + e.getMessage()); + Log.i(TAG, " Second onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" Second onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onComplete"); + Log.i(TAG, " Second onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/BehaviorSubjectExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/BehaviorSubjectExampleActivity.java index e398fd8..20305af 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/BehaviorSubjectExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/BehaviorSubjectExampleActivity.java @@ -71,28 +71,28 @@ private Observer getFirstObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " First onSubscribe : " + d.isDisposed()); + Log.i(TAG, " First onSubscribe : " + d.isDisposed()); } @Override public void onNext(Integer value) { textView.append(" First onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onNext value : " + value); + Log.i(TAG, " First onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" First onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onError : " + e.getMessage()); + Log.i(TAG, " First onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" First onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onComplete"); + Log.i(TAG, " First onComplete"); } }; } @@ -103,7 +103,7 @@ private Observer getSecondObserver() { @Override public void onSubscribe(Disposable d) { textView.append(" Second onSubscribe : isDisposed :" + d.isDisposed()); - Log.d(TAG, " Second onSubscribe : " + d.isDisposed()); + Log.i(TAG, " Second onSubscribe : " + d.isDisposed()); textView.append(AppConstant.LINE_SEPARATOR); } @@ -111,21 +111,21 @@ public void onSubscribe(Disposable d) { public void onNext(Integer value) { textView.append(" Second onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onNext value : " + value); + Log.i(TAG, " Second onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" Second onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onError : " + e.getMessage()); + Log.i(TAG, " Second onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" Second onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onComplete"); + Log.i(TAG, " Second onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/BufferExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/BufferExampleActivity.java index ead4b70..6c80b91 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/BufferExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/BufferExampleActivity.java @@ -68,18 +68,18 @@ private Observer> getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onNext(List stringList) { textView.append(" onNext size : " + stringList.size()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext : size :" + stringList.size()); + Log.i(TAG, " onNext : size :" + stringList.size()); for (String value : stringList) { textView.append(" value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " : value :" + value); + Log.i(TAG, " : value :" + value); } } @@ -88,14 +88,14 @@ public void onNext(List stringList) { public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/CompletableObserverExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/CompletableObserverExampleActivity.java index 1f7451a..12aa110 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/CompletableObserverExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/CompletableObserverExampleActivity.java @@ -59,21 +59,21 @@ private CompletableObserver getCompletableObserver() { return new CompletableObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ConcatExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ConcatExampleActivity.java index ce4a3f5..48fc29a 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ConcatExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ConcatExampleActivity.java @@ -63,28 +63,28 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onNext(String value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext : value : " + value); + Log.i(TAG, " onNext : value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/DebounceExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/DebounceExampleActivity.java index d0f9802..f96de70 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/DebounceExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/DebounceExampleActivity.java @@ -84,7 +84,7 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override @@ -93,22 +93,22 @@ public void onNext(Integer value) { textView.append(AppConstant.LINE_SEPARATOR); textView.append(" value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext "); - Log.d(TAG, " value : " + value); + Log.i(TAG, " onNext "); + Log.i(TAG, " value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/DeferExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/DeferExampleActivity.java index 4aed8c6..d41ea7d 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/DeferExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/DeferExampleActivity.java @@ -61,28 +61,28 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onNext(String value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext : value : " + value); + Log.i(TAG, " onNext : value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/DelayExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/DelayExampleActivity.java index 2979e75..de5a32d 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/DelayExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/DelayExampleActivity.java @@ -64,28 +64,28 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onNext(String value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext : value : " + value); + Log.i(TAG, " onNext : value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/DisposableExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/DisposableExampleActivity.java index 2dd124b..7055b88 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/DisposableExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/DisposableExampleActivity.java @@ -22,6 +22,7 @@ /** * Created by amitshekhar on 27/08/16. + * Using CompositeDisposable */ public class DisposableExampleActivity extends AppCompatActivity { @@ -66,26 +67,28 @@ void doSomeWork() { public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onNext(String value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext value : " + value); + Log.i(TAG, " onNext value : " + value); } })); } static Observable sampleObservable() { + // defer操作符是直到有订阅者订阅时，才通过Observable的工厂方法创建Observable并执行， + // defer操作符能够保证Observable的状态是最新的 return Observable.defer(new Callable>() { @Override public ObservableSource call() throws Exception { diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/DistinctExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/DistinctExampleActivity.java index 8e5f2f6..babacfc 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/DistinctExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/DistinctExampleActivity.java @@ -59,24 +59,24 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onNext(Integer value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext value : " + value); + Log.i(TAG, " onNext value : " + value); } @Override public void onError(Throwable e) { - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/FilterExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/FilterExampleActivity.java index e470182..79c78ee 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/FilterExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/FilterExampleActivity.java @@ -61,7 +61,7 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override @@ -70,22 +70,22 @@ public void onNext(Integer value) { textView.append(AppConstant.LINE_SEPARATOR); textView.append(" value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext "); - Log.d(TAG, " value : " + value); + Log.i(TAG, " onNext "); + Log.i(TAG, " value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/FlowableExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/FlowableExampleActivity.java index 7303cc2..e846f7c 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/FlowableExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/FlowableExampleActivity.java @@ -60,21 +60,21 @@ private SingleObserver getObserver() { return new SingleObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onSuccess(Integer value) { textView.append(" onSuccess : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onSuccess : value : " + value); + Log.i(TAG, " onSuccess : value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/IntervalExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/IntervalExampleActivity.java index 22469be..989a1cb 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/IntervalExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/IntervalExampleActivity.java @@ -73,21 +73,21 @@ private DisposableObserver getObserver() { public void onNext(Long value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext : value : " + value); + Log.i(TAG, " onNext : value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/LastOperatorExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/LastOperatorExampleActivity.java index b1c86ff..72f9a80 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/LastOperatorExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/LastOperatorExampleActivity.java @@ -57,14 +57,14 @@ private SingleObserver getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onSuccess(String value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext value : " + value); + Log.i(TAG, " onNext value : " + value); } @@ -72,7 +72,7 @@ public void onSuccess(String value) { public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/MapExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/MapExampleActivity.java index ccc6ace..2f0b8c0 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/MapExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/MapExampleActivity.java @@ -87,7 +87,7 @@ private Observer> getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override @@ -98,21 +98,21 @@ public void onNext(List userList) { textView.append(" firstname : " + user.firstname); textView.append(AppConstant.LINE_SEPARATOR); } - Log.d(TAG, " onNext : " + userList.size()); + Log.i(TAG, " onNext : " + userList.size()); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/MergeExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/MergeExampleActivity.java index 0cd7487..c742b76 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/MergeExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/MergeExampleActivity.java @@ -61,28 +61,28 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onNext(String value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext : value : " + value); + Log.i(TAG, " onNext : value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/PublishSubjectExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/PublishSubjectExampleActivity.java index af8822c..f120b5f 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/PublishSubjectExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/PublishSubjectExampleActivity.java @@ -68,28 +68,28 @@ private Observer getFirstObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " First onSubscribe : " + d.isDisposed()); + Log.i(TAG, " First onSubscribe : " + d.isDisposed()); } @Override public void onNext(Integer value) { textView.append(" First onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onNext value : " + value); + Log.i(TAG, " First onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" First onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onError : " + e.getMessage()); + Log.i(TAG, " First onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" First onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onComplete"); + Log.i(TAG, " First onComplete"); } }; } @@ -100,7 +100,7 @@ private Observer getSecondObserver() { @Override public void onSubscribe(Disposable d) { textView.append(" Second onSubscribe : isDisposed :" + d.isDisposed()); - Log.d(TAG, " Second onSubscribe : " + d.isDisposed()); + Log.i(TAG, " Second onSubscribe : " + d.isDisposed()); textView.append(AppConstant.LINE_SEPARATOR); } @@ -108,21 +108,21 @@ public void onSubscribe(Disposable d) { public void onNext(Integer value) { textView.append(" Second onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onNext value : " + value); + Log.i(TAG, " Second onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" Second onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onError : " + e.getMessage()); + Log.i(TAG, " Second onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" Second onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onComplete"); + Log.i(TAG, " Second onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReduceExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReduceExampleActivity.java index 1ab9930..733d7cd 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReduceExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReduceExampleActivity.java @@ -61,28 +61,28 @@ private MaybeObserver getObserver() { return new MaybeObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onSuccess(Integer value) { textView.append(" onSuccess : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onSuccess : value : " + value); + Log.i(TAG, " onSuccess : value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReplayExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReplayExampleActivity.java index 8880ea9..827b7c3 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReplayExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReplayExampleActivity.java @@ -69,28 +69,28 @@ private Observer getFirstObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " First onSubscribe : " + d.isDisposed()); + Log.i(TAG, " First onSubscribe : " + d.isDisposed()); } @Override public void onNext(Integer value) { textView.append(" First onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onNext value : " + value); + Log.i(TAG, " First onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" First onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onError : " + e.getMessage()); + Log.i(TAG, " First onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" First onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onComplete"); + Log.i(TAG, " First onComplete"); } }; } @@ -101,7 +101,7 @@ private Observer getSecondObserver() { @Override public void onSubscribe(Disposable d) { textView.append(" Second onSubscribe : isDisposed :" + d.isDisposed()); - Log.d(TAG, " Second onSubscribe : " + d.isDisposed()); + Log.i(TAG, " Second onSubscribe : " + d.isDisposed()); textView.append(AppConstant.LINE_SEPARATOR); } @@ -109,19 +109,19 @@ public void onSubscribe(Disposable d) { public void onNext(Integer value) { textView.append(" Second onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onNext value : " + value); + Log.i(TAG, " Second onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" Second onError : " + e.getMessage()); - Log.d(TAG, " Second onError : " + e.getMessage()); + Log.i(TAG, " Second onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" Second onComplete"); - Log.d(TAG, " Second onComplete"); + Log.i(TAG, " Second onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReplaySubjectExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReplaySubjectExampleActivity.java index 7f09563..5a4fa4f 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReplaySubjectExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReplaySubjectExampleActivity.java @@ -67,28 +67,28 @@ private Observer getFirstObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " First onSubscribe : " + d.isDisposed()); + Log.i(TAG, " First onSubscribe : " + d.isDisposed()); } @Override public void onNext(Integer value) { textView.append(" First onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onNext value : " + value); + Log.i(TAG, " First onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" First onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onError : " + e.getMessage()); + Log.i(TAG, " First onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" First onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " First onComplete"); + Log.i(TAG, " First onComplete"); } }; } @@ -99,7 +99,7 @@ private Observer getSecondObserver() { @Override public void onSubscribe(Disposable d) { textView.append(" Second onSubscribe : isDisposed :" + d.isDisposed()); - Log.d(TAG, " Second onSubscribe : " + d.isDisposed()); + Log.i(TAG, " Second onSubscribe : " + d.isDisposed()); textView.append(AppConstant.LINE_SEPARATOR); } @@ -107,21 +107,21 @@ public void onSubscribe(Disposable d) { public void onNext(Integer value) { textView.append(" Second onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onNext value : " + value); + Log.i(TAG, " Second onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" Second onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onError : " + e.getMessage()); + Log.i(TAG, " Second onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" Second onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " Second onComplete"); + Log.i(TAG, " Second onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ScanExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ScanExampleActivity.java index f70e667..3fb4f79 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ScanExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ScanExampleActivity.java @@ -63,28 +63,28 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onNext(Integer value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext value : " + value); + Log.i(TAG, " onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/SimpleExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/SimpleExampleActivity.java index 423047d..d53f622 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/SimpleExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/SimpleExampleActivity.java @@ -53,7 +53,7 @@ private void doSomeWork() { } private Observable getObservable() { - return Observable.just("Cricket", "Football"); + return Observable.just("Cricket", "Football"); // 板球 } private Observer getObserver() { @@ -61,28 +61,28 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onNext(String value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext : value : " + value); + Log.i(TAG, " onNext : value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/SingleObserverExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/SingleObserverExampleActivity.java index 6c9ce7c..b25416a 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/SingleObserverExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/SingleObserverExampleActivity.java @@ -50,21 +50,21 @@ private SingleObserver getSingleObserver() { return new SingleObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onSuccess(String value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext value : " + value); + Log.i(TAG, " onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/SkipExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/SkipExampleActivity.java index 26706ea..78f6848 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/SkipExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/SkipExampleActivity.java @@ -62,28 +62,28 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onNext(Integer value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext value : " + value); + Log.i(TAG, " onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/TakeExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/TakeExampleActivity.java index ae71924..b2df89c 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/TakeExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/TakeExampleActivity.java @@ -62,28 +62,28 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onNext(Integer value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext value : " + value); + Log.i(TAG, " onNext value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ThrottleFirstExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ThrottleFirstExampleActivity.java index 28c6ae7..8713e01 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ThrottleFirstExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ThrottleFirstExampleActivity.java @@ -89,7 +89,7 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override @@ -98,22 +98,22 @@ public void onNext(Integer value) { textView.append(AppConstant.LINE_SEPARATOR); textView.append(" value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext "); - Log.d(TAG, " value : " + value); + Log.i(TAG, " onNext "); + Log.i(TAG, " value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ThrottleLastExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ThrottleLastExampleActivity.java index 95b6a45..212ae11 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ThrottleLastExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ThrottleLastExampleActivity.java @@ -88,7 +88,7 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override @@ -97,22 +97,22 @@ public void onNext(Integer value) { textView.append(AppConstant.LINE_SEPARATOR); textView.append(" value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext "); - Log.d(TAG, " value : " + value); + Log.i(TAG, " onNext "); + Log.i(TAG, " value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/TimerExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/TimerExampleActivity.java index 17f6369..60c41c7 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/TimerExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/TimerExampleActivity.java @@ -63,28 +63,28 @@ private Observer getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override public void onNext(Long value) { textView.append(" onNext : value : " + value); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onNext : value : " + value); + Log.i(TAG, " onNext : value : " + value); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/WindowExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/WindowExampleActivity.java index 672d3ce..b204ff6 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/WindowExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/WindowExampleActivity.java @@ -1 +1 @@ -package com.rxjava2.android.samples.ui.operators; import android.os.Bundle; import android.support.v7.app.AppCompatActivity; import android.util.Log; import android.view.View; import android.widget.Button; import android.widget.TextView; import com.rxjava2.android.samples.R; import com.rxjava2.android.samples.utils.AppConstant; import java.util.concurrent.TimeUnit; import io.reactivex.Observable; import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.functions.Consumer; import io.reactivex.schedulers.Schedulers; public class WindowExampleActivity extends AppCompatActivity { private static final String TAG = WindowExampleActivity.class.getSimpleName(); Button btn; TextView textView; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_example); btn = (Button) findViewById(R.id.btn); textView = (TextView) findViewById(R.id.textView); btn.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View view) { doSomeWork(); } }); } /* * Example using window operator -> It periodically * subdivide items from an Observable into * Observable windows and emit these windows rather than * emitting the items one at a time */ protected void doSomeWork() { Observable.interval(1, TimeUnit.SECONDS).take(12) .window(3, TimeUnit.SECONDS) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(getConsumer()); } public Consumer> getConsumer() { return new Consumer>() { @Override public void accept(Observable observable) throws Exception { Log.d(TAG, "Sub Divide begin...."); textView.append("Sub Divide begin ...."); textView.append(AppConstant.LINE_SEPARATOR); observable .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Consumer() { @Override public void accept(Long value) { Log.d(TAG, "Next:" + value); textView.append("Next:" + value); textView.append(AppConstant.LINE_SEPARATOR); } }); } }; } } \ No newline at end of file +package com.rxjava2.android.samples.ui.operators; import android.os.Bundle; import android.support.v7.app.AppCompatActivity; import android.util.Log; import android.view.View; import android.widget.Button; import android.widget.TextView; import com.rxjava2.android.samples.R; import com.rxjava2.android.samples.utils.AppConstant; import java.util.concurrent.TimeUnit; import io.reactivex.Observable; import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.functions.Consumer; import io.reactivex.schedulers.Schedulers; public class WindowExampleActivity extends AppCompatActivity { private static final String TAG = WindowExampleActivity.class.getSimpleName(); Button btn; TextView textView; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_example); btn = (Button) findViewById(R.id.btn); textView = (TextView) findViewById(R.id.textView); btn.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View view) { doSomeWork(); } }); } /* * Example using window operator -> It periodically * subdivide items from an Observable into * Observable windows and emit these windows rather than * emitting the items one at a time */ protected void doSomeWork() { Observable.interval(1, TimeUnit.SECONDS).take(12) .window(3, TimeUnit.SECONDS) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(getConsumer()); } public Consumer> getConsumer() { return new Consumer>() { @Override public void accept(Observable observable) throws Exception { Log.i(TAG, "Sub Divide begin...."); textView.append("Sub Divide begin ...."); textView.append(AppConstant.LINE_SEPARATOR); observable .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Consumer() { @Override public void accept(Long value) { Log.i(TAG, "Next:" + value); textView.append("Next:" + value); textView.append(AppConstant.LINE_SEPARATOR); } }); } }; } } \ No newline at end of file diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java index af446f3..19465fa 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java @@ -97,7 +97,7 @@ private Observer> getObserver() { @Override public void onSubscribe(Disposable d) { - Log.d(TAG, " onSubscribe : " + d.isDisposed()); + Log.i(TAG, " onSubscribe : " + d.isDisposed()); } @Override @@ -108,21 +108,21 @@ public void onNext(List userList) { textView.append(" firstname : " + user.firstname); textView.append(AppConstant.LINE_SEPARATOR); } - Log.d(TAG, " onNext : " + userList.size()); + Log.i(TAG, " onNext : " + userList.size()); } @Override public void onError(Throwable e) { textView.append(" onError : " + e.getMessage()); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onError : " + e.getMessage()); + Log.i(TAG, " onError : " + e.getMessage()); } @Override public void onComplete() { textView.append(" onComplete"); textView.append(AppConstant.LINE_SEPARATOR); - Log.d(TAG, " onComplete"); + Log.i(TAG, " onComplete"); } }; } diff --git a/app/src/main/java/com/rxjava2/android/samples/utils/Utils.java b/app/src/main/java/com/rxjava2/android/samples/utils/Utils.java index 04695b2..3b728c3 100644 --- a/app/src/main/java/com/rxjava2/android/samples/utils/Utils.java +++ b/app/src/main/java/com/rxjava2/android/samples/utils/Utils.java @@ -136,15 +136,15 @@ public static void logError(String TAG, Throwable e) { // error.getErrorCode() - the ANError code from server // error.getErrorBody() - the ANError body from server // error.getErrorDetail() - just a ANError detail - Log.d(TAG, "onError errorCode : " + anError.getErrorCode()); - Log.d(TAG, "onError errorBody : " + anError.getErrorBody()); - Log.d(TAG, "onError errorDetail : " + anError.getErrorDetail()); + Log.i(TAG, "onError errorCode : " + anError.getErrorCode()); + Log.i(TAG, "onError errorBody : " + anError.getErrorBody()); + Log.i(TAG, "onError errorDetail : " + anError.getErrorDetail()); } else { // error.getErrorDetail() : connectionError, parseError, requestCancelledError - Log.d(TAG, "onError errorDetail : " + anError.getErrorDetail()); + Log.i(TAG, "onError errorDetail : " + anError.getErrorDetail()); } } else { - Log.d(TAG, "onError errorMessage : " + e.getMessage()); + Log.i(TAG, "onError errorMessage : " + e.getMessage()); } } From ea9f335ae83e6402de769e1c4f2c47d549ebc02b Mon Sep 17 00:00:00 2001 From: lh <642404044@qq.com> Date: Wed, 12 Jul 2017 18:20:47 +0800 Subject: [PATCH 3/3] =?UTF-8?q?=E6=B5=8B=E8=AF=95RxJava?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/build.gradle | 1 + app/src/main/AndroidManifest.xml | 3 + .../android/samples/ui/SelectionActivity.java | 5 + .../android/samples/ui/test/TestActivity.java | 112 ++++++++++++++++++ .../main/res/layout/activity_selection.xml | 7 ++ app/src/main/res/values/strings.xml | 1 + 6 files changed, 129 insertions(+) create mode 100644 app/src/main/java/com/rxjava2/android/samples/ui/test/TestActivity.java diff --git a/app/build.gradle b/app/build.gradle index 8b820a1..744ffc8 100644 --- a/app/build.gradle +++ b/app/build.gradle @@ -27,4 +27,5 @@ dependencies { compile 'io.reactivex.rxjava2:rxjava:2.0.6' compile 'io.reactivex.rxjava2:rxandroid:2.0.1' compile 'com.amitshekhar.android:rx2-android-networking:1.0.0' + compile 'com.jakewharton.rxbinding2:rxbinding:2.0.0' } diff --git a/app/src/main/AndroidManifest.xml b/app/src/main/AndroidManifest.xml index 0d04bd1..560c0e7 100644 --- a/app/src/main/AndroidManifest.xml +++ b/app/src/main/AndroidManifest.xml @@ -124,6 +124,9 @@ + \ No newline at end of file diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/SelectionActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/SelectionActivity.java index 8bdd4c3..23fa1f0 100644 --- a/app/src/main/java/com/rxjava2/android/samples/ui/SelectionActivity.java +++ b/app/src/main/java/com/rxjava2/android/samples/ui/SelectionActivity.java @@ -11,6 +11,7 @@ import com.rxjava2.android.samples.ui.networking.NetworkingActivity; import com.rxjava2.android.samples.ui.pagination.PaginationActivity; import com.rxjava2.android.samples.ui.rxbus.RxBusActivity; +import com.rxjava2.android.samples.ui.test.TestActivity; /** * 选择页面 @@ -43,4 +44,8 @@ public void startPaginationActivity(View view) { public void startComposeOperator(View view) { startActivity(new Intent(SelectionActivity.this, ComposeOperatorExampleActivity.class)); } + + public void test(View view) { + startActivity(new Intent(SelectionActivity.this, TestActivity.class)); + } } diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/test/TestActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/test/TestActivity.java new file mode 100644 index 0000000..c5aabbc --- /dev/null +++ b/app/src/main/java/com/rxjava2/android/samples/ui/test/TestActivity.java @@ -0,0 +1,112 @@ +package com.rxjava2.android.samples.ui.test; + +import android.os.Bundle; +import android.support.v7.app.AppCompatActivity; +import android.util.Log; +import android.widget.Button; +import android.widget.TextView; + +import com.jakewharton.rxbinding2.view.RxView; +import com.rxjava2.android.samples.R; +import com.rxjava2.android.samples.utils.AppConstant; + +import java.util.concurrent.TimeUnit; + +import io.reactivex.Observable; +import io.reactivex.Observer; +import io.reactivex.android.schedulers.AndroidSchedulers; +import io.reactivex.disposables.Disposable; +import io.reactivex.schedulers.Schedulers; + +/** + * Created by we-win on 2017/7/12. + */ + +public class TestActivity extends AppCompatActivity { + + private static final String TAG = TestActivity.class.getSimpleName(); + Button btn; + TextView textView; + + @Override + protected void onCreate(Bundle savedInstanceState) { + super.onCreate(savedInstanceState); + setContentView(R.layout.activity_example); + btn = (Button) findViewById(R.id.btn); + textView = (TextView) findViewById(R.id.textView); + +// btn.setOnClickListener(new View.OnClickListener() { +// @Override +// public void onClick(View view) { +// doSomeWork(); +// } +// }); + doSomeWork(); + } + + /* + * simple example to emit two value one by one + */ + private void doSomeWork() { + RxView.clicks(btn) + .throttleFirst(1, TimeUnit.SECONDS) + // Run on a background thread + .subscribeOn(Schedulers.io()) + // Be notified on the main thread + .observeOn(AndroidSchedulers.mainThread()) + .subscribe(new Observer() { + @Override + public void onSubscribe(Disposable disposable) { + Log.i(TAG, " onSubscribe : " + disposable.isDisposed()); + } + @Override + public void onNext(Object o) { + Log.i(TAG, " onNext : value : "); + } + @Override + public void onError(Throwable throwable) { + Log.i(TAG, " onError : " + throwable.getMessage()); + } + @Override + public void onComplete() { + Log.i(TAG, " onComplete"); + } + }); + } + + private Observable getObservable() { + return Observable.just("Cricket", "Football"); // 板球 + } + + private Observer getObserver() { + return new Observer() { + + @Override + public void onSubscribe(Disposable d) { + Log.i(TAG, " onSubscribe : " + d.isDisposed()); + } + + @Override + public void onNext(String value) { + textView.append(" onNext : value : " + value); + textView.append(AppConstant.LINE_SEPARATOR); + Log.i(TAG, " onNext : value : " + value); + } + + @Override + public void onError(Throwable e) { + textView.append(" onError : " + e.getMessage()); + textView.append(AppConstant.LINE_SEPARATOR); + Log.i(TAG, " onError : " + e.getMessage()); + } + + @Override + public void onComplete() { + textView.append(" onComplete"); + textView.append(AppConstant.LINE_SEPARATOR); + Log.i(TAG, " onComplete"); + } + }; + } + +} diff --git a/app/src/main/res/layout/activity_selection.xml b/app/src/main/res/layout/activity_selection.xml index 063101a..8cff09c 100644 --- a/app/src/main/res/layout/activity_selection.xml +++ b/app/src/main/res/layout/activity_selection.xml @@ -50,5 +50,12 @@ android:text="@string/compose" android:textColor="@android:color/black" /> +