#java #reactiveprogramming #programowanie

Może głupie pytanie ale jakoś nie potrafię znaleźć odpowiedzi na to pytanie ani sam dojść do jakiś sensownych wniosków.

Załóżmy że mamy jakiś kod w zewnętrznej bibliotece który wykonuje asynchroniczny strzał do jakiegoś serwisu, tego kodu nie możesz zmienić.

Pytanie co by można zrobić aby zamienić powyższy kod na podejście reaktywne, czy możemy opakować kod w ten sposób?
Mono.fromSupplier() ->asyncCall())

Czy event loop nie będzie miał problemów z obsługą
tworzysz osobną dedykowaną pule wątków i scheduler który ma obsługiwać tą biblioteke tak że jak sie coś tam wywali to nie ubije ci wszystkiego
Witam,

chciałbym z wami się podzielić moją paczką do obsługiwania zdarzeń. Napisałem ją za pomocą TypeScripta i RxJs. Może komuś się przyda. osobiście wykorzystuje ją w swoim projekcie a pomyślałem, że komuś może się przyda. Jak sama nazwa mówi. Jest to bardzo prosta paczka do obsługi zdarzeń.
Wiem, że brakuje do niej testów ale w najbliższej przyszłości planuje oczywiście takie testy dodać.

Link do paczki: https://www.npmjs.com/package/@antyper/simple-event-bus

#programowanie #reactiveprogramming #typescript #javascript
#programowanie #javascript #reactiveprogramming

Co oznacza zapis funkcji w dokumentacji #rxjs?
Chodzi mi dokładnie o zapis funkcji project w mergeMap. Rozumiem, że przyjmuje ona argument i mnożony jest razy 10. A co oznaczają dwa myślniki i pionowa linia na końcu? Dlaczego potrojony jest zapis 10*i? Czy może to nie jest ogólny zapis ale rozpisanie konkretnego przykładu?

https://rxjs-dev.firebaseapp.com/api/operators/mergeMap
ziolo86 - #programowanie #javascript #reactiveprogramming

Co oznacza zapis funkcji...

źródło: comment_EAq5JZcVcIRcDoMxL7wCLqawp5aRbAg2.jpg

Pobierz
@ziolo86:
Zapis z myślnikami to pochodna wykorzystania rxjs-marbles do testów jednostkowych. Ta biblioteka pozwala na zapisanie Observable jako stringa, podwójny myślnik to separator elementów w strumieniu danych Observable.

mergeMap ma dwa zadania: dla każdego elementu z źródłowego obserwable wykonuje funkcję przekazaną jako argument, ta funkcja ma zwrócić Observeble | Promise | Array. Następnie mergeMap subskrybuje otrzymane Observable i zwraca scala wyniki tych Observable w jedno wynikowe Obresvable.
Należy pamiętać, że wynik
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)
@shus:
Koncept 'Reactive Programming' to taki bardziej rozbuchany Observer Pattern, nic innego. Ciężko mówić o 'przyszłości\ czy pomyłce. Ot, czasem można użyć, czasem nie, za rok, dwa nikt nie będzie o tym pamiętał.

A do Springa nic nie ma porównania, w którym by się choć trochę zbliżyło do niego :)
#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