RxJava2-Android-Samples
RxJava2-Android-Samples copied to clipboard
RxJava 2 Android Examples - How to use RxJava 2 in Android
Hi, what are the best practice to dispose subscriber? In my application in few places memory is getting leak because of late dispose (ex: disposing only in onDestroy)
When I click on keyboard button "actionSearch" observer call "onComplete" and observable do not react on text changed event.
I want to show priogressDialog in the "search" implementation. But, Not finding where to put the "showProgressDialog()" method.
Not able to see the Activity code properly in GitHub source code viewer, Somethings wrong with codes formatting. https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/WindowExampleActivity.java
In [Using Disposable in RxJava](https://mindorks.com/course/learn-rxjava/chapter/id/4/page/id/16 ) `disposables.clear()` is invoked in `onStop()` But in the comment and also [Github](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/50cc3c388f93ebd3734264c5efe0bb09a6b027ff/app/src/main/java/com/rxjava2/android/samples/ui/operators/DisposableExampleActivity.java) `disposables.clear()` is invoked in `onDestroy()` BTW, there are several typos on the...
Any idea how to handle "thread interrupted"? This happens due to calling the instant search api! Thank you.
Please add this sample operators. Thankyou :)
private Observable getObservable() { return Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(ObservableEmitter emitter) throws Exception { // send events with simulated time wait //下面的注释是作者原注释,我觉得不太对,因为这个运行的结果是1,3,7被发送出来了 Thread.sleep(0); emitter.onNext(1); // skip emitter.onNext(2); //...