Hej, jw.
Z tego co wyczytałem, RxJava to:
'A library for composing asynchronous and event-based programs using observable sequences for the Java VM'
- Domyślnie RxJava opiera się na main threadzie, więc czy w takim wypadku jest wgl sens używać RxJavy bazując tylko po jednym threadzie? (pomijając bardziej rozbudowane stream api)
- Polecicie jakiś projekcik na gicie/tutorial/cokolwiek jakiś projekcik jak używać RxJave aby korzystać z niej asynchronicznie?
Chciałbym tak tylko zerknąć na temat, 2-3 dni żeby zrozumieć idee i podstawy.
Dzięki za odpowiedzi.
Michał Sikorasource.compose(::nonBlockingOnSourcePool).map(::mapper)wątek na którym coś zostało wyemitowane i na którym coś zostało zmapowane będzie ten sam, co nie jest prawdą.publishOnlubsubscribeOn, aby przełączyć przetwarzanie między schedulerami (pulami wątków).Michał Sikoradelaynp. samo przełączy pulę, jak się nie poda własnej.timeoutczydebounce, podstępnie jest użyty globalnySchedulers.computation(), przynajmniej w RxJavie. Myślę, że bezpieczniej rzeczywiście byłoby napisać, że RxJava nie robi żadnych założeń odnośnie wątku, na którym odpali się dany operator przy czym z przyczyn wydajnościowych stara się ograniczać zmiany kontekstu do minimum.