¯\_(ツ)_/¯ zalezy co cie interesuje... Achaje tez uznaje za wartosciowa ksiazke ale z IT ma tyle do czynienia co nic. introduction to modern cryptography jest super, ale malo praktyczna. clean code i effective java sa spoko. co do androida, raczej zazwyczaj czytam doku+ ewentualnie na medium jakies przyklady
  • Odpowiedz
@madnes77: Samo tłumaczenie w pierwszym punkcie jest jak dla mnie niejasne. Dużo bardziej trafia do mnie wytłumaczenie tego na przykładzie komórek z excela.
Brakuje też jakiegoś trochę szerszego opisu i wytłumaczenia .just()
To tyle z czepiania się :P
  • Odpowiedz
@Rubajticos: flatMapCompletable pozwala na mapowanie na Completable. W twoim przypadku dla każdego elementu zwróconego z piggyWithContributionsRepository.getOne() zostanie wykonany piggyWithContribitions.getPiggy().setActualAmount. Completable różni się od Flowable tym, że nie zwraca elementów tylko Success lub Error.
Dlaczego to wykonuje się w kółko?
Podejrzewam, że piggyWithContributionsRepository.getOne() to jest subskrybcja na repozytorium opartej o bazę danych przy wykorzystaniu Room. Jedna z akcji piggyWithContribitions.getPiggy().setActualAmount() lub piggyRepository.updateWithCallback() prawdopodobnie modyfikuje bazę, a to powoduje, że piggyWithContributionsRepository.getOne() publikuje
  • Odpowiedz
@nocneszczury: metoda publish(), która z Observable robi ConnectedObservable i refCount(), która automatycznie robi dispose, gdy nie ma obserwatorów. Jest ma się wykonać jakiś kod na końcu to masz doFinally(), doOnComplete(), doOnError(). Coś wybierzesz.
  • Odpowiedz
Czy ktoś miał styczność ze wzorcem repository w Androidzie? Chcę zrobić coś takiego jak tu(sekcja Addendum) w RxJavie, a nie w LiveDacie. Chodzi mi o wrapowanie danych w klasę Resource z enumem oznaczającym status pobrania zasobu z API. Nie wiem jakich transformacji mogę użyć, żeby coś takiego osiągnąć. Dla przykładu moje DAO zwraca Flowable, a webservice Single i muszę wrapować te eventy z Flowable w Resource ze statusem LOADING dopóki nie otrzymam
@stefansiarrasiarzewski: fajny artykuł. Dobrze, że google w końcu to opisuje. No właśnie w tym sęk, że RxJava jest zbyt skomplikowana od trywialnych zadań jakie programiści Androida zwykle napotykają. Generalnie do tego co chcesz wystarczy .map(), bo map pozwala zmienić emitowany obiekt na obiekt innego typu. Nie pozwól, żeby z twojego łańcucha rxjavy ktoś rzucił exception, bo wtedy mimo onError łańcuch jest już zakończony. (taka dobra rada dla początkujących)
  • Odpowiedz
#androiddev #java #reactive #rxjava #programowanie
Mirki, niedawno w pracbaza zaczęliśmy się przerzucać na reaktywne programowanie.
W związku z tym nasi przełożeni zgodzili się wykupić nam jakies fajne kursy online, i tutaj pytanie:
Jakie kursy byście polecili?
W grę wchodzą tylko kursy anglojęzyczne. Mamy już wykupiony drogi kurs face-to-face ale termin jest za 1.5 miesiąca i idea jest aby do tego czasu ogarnąć podstawy rxJava2 na tyle aby się nie pogubić na kursie.
@Bratkello Jak już pisałem mamy już wynajętą taką osobę za odpowiednią kwotę, teraz potrzebujemy jakiegoś kursu online, z którego będziemy mogli nauczyć się podstaw na tyle, aby jak najwięcej z kursu face to face wycisnąć.
  • Odpowiedz
#androiddev #java #android #retrofit #rxjava #rest #geojson

Witajcie mirki, mam nastepujacy problem:
Uzywam RxJava 2 z Retrofitem, do Retrofita uzywam tez RxJava2 adapter, aby moc zwracac z resta Observables, do tego uzywam convertera gson : "com.squareup.retrofit2:converter-gson". Moj problem polega na tym, ze zaszla potrzeba parsowania GeoJson i nie jestem pewien jak to ogarnac za pomoca tych narzedzi, ktorych uzywam. Na chwile obecna stworzylem sobie concrete model z tablica double gdzie laduje sobie
#programowanie #rxjava

Mam taki problem: Posiadam dwa strumienie. jeden to np bazadanych drugie api
Te dwa strumienie łacze metodą concat(). Z np concat(baza, api)
z załozenia concat pierw #!$%@? pierwszy strumien do konca a dopiero pozniej kolejny.
U mnie strumienie są obserwowane obserwowane na watku w tle, a subscrybowane na watku UI.
Wszystko dziala pieknie jak oba strumienie przesylaja dane, lecz np jak odetne net, to baza ładnie konczy przygotowywac dane i
Cześć Mirki,
Pytanie do tych, którzy ogarniają #rxjava - jakie zasoby polecacie? Krążę ostatnio po internecie i szukam różnych źródeł z racji tego, że podjąłem decyzję o nauce, ale w sumie nie ma tego aż tak dużo jak mogłoby się wydawać. Na razie znalazłem blog http://akarnokd.blogspot.com/ i wydaje się interesujący. Z czego korzystaliście podczas nauki?
Pozdrawiam
#java #androiddev
@Dante651: Dan Lew świetnie tłumaczy.
Do nauki podstaw ta seria -> http://blog.danlew.net/2014/09/15/grokking-rxjava-part-1/
+ reszta blog postów.

Obejrzyj też tę prezkę -> https://www.youtube.com/watch?v=QdmkXL7XikQ

Ten blog co podałeś to są bardzo zaawansowane rzeczy, w większości gościu pisze o wewnętrznych komponentach Rx.

Warto też przejrzeć z grubsza wszystkie dostępne operatory -> http://reactivex.io/documentation/operators.html
Nie ma tego tak dużo.
  • Odpowiedz
@robcioo1994:
Firma, w której zaczynam pracę za tydzień (Kraków, 150 osób) używa tego jako podstawy backendu. Poza tym, właśnie wróciłem z trzydniowej konferencji javowej (Devoxx) i tematy RxJavy i programowania reaktywnego i asynchroniczności były jednym z popularnijszych (zaraz po mikroserwisach i chmurze). Sporo firm, które przetwarzają ogromne ilości danych (Netflix, Sky, Linkedin) postawiły na nieblokujące, asynchroniczne operacje, które RxJava świetnie implementuje. Co do pytania "Czy oplaca się uczyć" - moim zdaniem
  • Odpowiedz
Potrzebuję skorzystać z api (giełdy btc) na protokole #wamp w #java. Jest do tego biblioteka jawampa, wykorzystująca #rxjava, którego nie znam (ogólnie nigdy nie korzystałem z rx). Czy ogarnićecie rxjava w takim stopniu, żeby pobierać dane giełdowe będzie czymś wymagającym, czy da radę w ~kilka godzin? Polecicie jakieś proste materiały z przykładami (po polsku albo angielsku)?
#programowanie #java #rxjava #reactiveprogramming #rectiveextensions #reactive

Może ktoś pomóc? Czy jest taki operator, który pozwala na buforowanie emitowanych elementów według takiego schematu:
- początek buforowania następuje wtedy kiedy odstęp pomiędzy poszczególnymi emisjami jest mniejszy niż 1 s
- koniec buforowania jest wtedy kiedy nie ma żadnej emisji od 0,5 s

Operator window i buffer mają coś takiego jak opening selector i closing selector, ale nie mam pojęcia jak to działa i czy