올해는 머신러닝이다.

https://medium.com/@aristides.papadopoulos/completable-to-single-boolean-in-rxjava2-2cb65cc9b613

Our Top Nine Learnings from Migrating from RxJava 1 to RxJava 2 https://www.runtastic.com/blog/en/tech/rxjava-2-migration-learnings/?utm_source=Android+Weekly&utm_campaign=e254d2512b-androidweekly-285&utm_medium=email&utm_term=0_4eb677ad19-e254d2512b-338106413

요구사항내 응용 프로그램에서는 최근에 다음과 같은 요구 사항이 있습니다. 항목의 반응적인 스트림에서 특정 항목이 하나 방출 될 때까지 기다린 다음 모든 항목을 관찰자에게 내 보냅니다. 해당 항목을 찾을 수 없으면 아무 것도 출력하지 말고 오류로 종료하십시오. https://medium.com/@Cypressious/rxjava-kotlin-conditionally-delaying-the-first-item-in-a-stream-9d4e7a8d0071

만약 Backpressure없는 Flowable을 사용시 어떤 함수를 사용하면 좋은지 알아보자.우선 onBackpressureBuffer() 을 알아보자.복습을 하자면Flowable.interval( 1, TimeUnit.MILLISECONDS) .observeOn(Schedulers.io()) .subscribe(i -> { sleep(5); System.out.println("Received MyItem : " + i); }); 을 사용시 배출이 생성하는 것을 못 따라주기 때문에 오류가 난다.Received MyItem : 21 Received MyItem : 22 Received MyItem : 23 Received MyItem : 24 io.reactivex.exceptions.OnErrorNot..

http://leandrofavarin.com/exponential-backoff-rxjava-operator-with-jitter

https://balamaci.github.io/rxjava-walkthrough/

출처: http://doohyun.tistory.com/44 [N`s Lab] List subjectRelationList = Arrays.asList( new SubjectRelation(1, 1001, "Doohyun Nam", 1) , new SubjectRelation(1, 1002, "Dolkin", 2) , new SubjectRelation(1, 1003, "hshawng", 1) , new SubjectRelation(1, 1004, "spKwon", 1) , new SubjectRelation(2, 1005, "Other Person1", 3) , new SubjectRelation(2, 1006, "Other Person2", 4) ); // create MapMap mapTest = ..

Rxjava2 Extrashttps://github.com/davidmoten/rxjava2-extras RxJava2 Extentionshttps://github.com/akarnokd/RxJava2Extensions

출처 : https://stackoverflow.com/a/43343039Observable observable1 = Observable.from(new String[]{"A", "B", "C", "D"}); Observable observable2 = Observable.from(new String[]{"E", "C", "B", "G", "J", "O"}); observable1.concatMap(new Func1() { @Override public Observable call(final String string) { return observable2.contains(string); } }).zipWith(observable1, new Func2() { @Override public String ca..

출처 : https://github.com/ReactiveX/RxAndroid/wiki RxLifecycle - Lifecycle handling APIs for Android apps using RxJavaRxBinding - RxJava binding APIs for Android's UI widgets.SqlBrite - A lightweight wrapper around SQLiteOpenHelper and ContentResolver which introduces reactive stream semantics to queries.Android-ReactiveLocation - Library that wraps location play services API boilerplate with a re..

/*** * This is a helper wrapper Subscriber that helps you lazily defer * continuous paging of a result set from some API. * Through the use of a {@link Subject}, it helps notify the original {@link Observable} * when to perform an additional fetch. * The notification is sent when a certain count of items has been reached. * Generally this count represents the page. * @param The event type */ @Da..

https://medium.com/rainist-engineering/migrate-from-rxjava1-to-rxjava2-3aea3ff9051c

http://realignist.me/code/2017/01/25/rxjava2-changelog.html

rxjava 가 메이저 버전 업(1->2)을 하면서 몇 가지 변경점이 생겼다.변경점에 대한 자세한 내용은 아래 링크를 참조하기 바란다.rxJava Wiki : https://github.com/ReactiveX/RxJava/wiki/What’s-different-in-2.0번역 : http://realignist.me/code/2017/01/25/rxjava2-changelog.htmlFlowable 이라는 base reactive class 가 추가 되었다. Observable 과의 차이는 backpressure buffer의 기본 탑재 유무이다.

출처 : https://stackoverflow.com/a/42005735I'd suggest using a Single as it is more accurate representation of the data flow: you make a request to the server and the you get either one emission of data OR an error:Single: onSubscribe (onSuccess | onError)?For an Observable you could theoretically get several emissions of data AND an errorObservable: onSubscribe onNext? (onCompleted | onError)?How..

https://android.jlelse.eu/mvp-dagger-2-rx-clean-modern-android-app-code-74f63c9a6f2f