sdasdadawqeqawdas
sdasdadawqeqawdas
#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
0
  • Najlepsze
  • Wszystkie komentarze
globalbus
globalbus
@sdasdadawqeqawdas: jak się da, to dopisanie kodu do tego syfu. Jak się nie da, to tak jak podałeś wyżej, ale będzie się to wykonywało na innej puli wątków i mogą być efekty uboczne
1
globalbus
globalbus
@sdasdadawqeqawdas: ale asynchroniczny strzał z biblioteki zwraca co? Future , voida, czy jak?
0
inny_89
#scala #reactiveprogramming
Jakbyście nie znali to ciekawy kontent znalazłem https://medium.com/disney-streaming/tagged/thisweekinscala
2
pyra991
pyra991
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
2
  • Najlepsze
  • Wszystkie komentarze
u_k1
Taktyk żeby zajrzeć potem ( ͡° ͜ʖ ͡°)
1
z.....6
#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
0
  • Najlepsze
  • Wszystkie komentarze
Verbatino
@ziolo86: To tylko prezentacja.
1
ksm123
@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
1
konik_polanowy
17
  • Najlepsze
  • Wszystkie komentarze
konik_polanowy
1
konik_polanowy
1
stefansiarrasiarzewski
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
1
  • Najlepsze
  • Wszystkie komentarze
z.....6
#javascript #reactiveprogramming #rxjs

Otrzymuje Observable z Promise, który może zawierać obiekt z właściwością status_code 200 lub 500.
Jak mogę (bez if) wyświetlić alert dla każdego ze statusu?
1
  • Najlepsze
  • Wszystkie komentarze
Wyrewolwerowanyrewolwer
Przy tworzeniu nowego projektu w IntelliJ jako Spring Initzr pojawił się pakiet reactive jako wersja eksperymentalna.

#spring #java #reactiveprogramming
4
shus
shus
Korzystał ktoś z playframework i ma jakieś porównanie do Springu? W przypadku playa jak rzuciłem okiem na dokumentację wygląda dosyć ciekawe i dzięki zastosowaniu reactiveprogramming mamy dużo mniej kodu w projekcie, choć jak dla mnie jest on mniej czytelny.

I ogólnie co myślicie na temat programowania "reactive", przyszłość czy pomyłka?

#playframework #spring #java #reactiveprogramming #programowanie
2
  • Najlepsze
  • Wszystkie komentarze
siemanko
#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
2
  • Najlepsze
  • Wszystkie komentarze
g.....s
g.....s
Czy ktoś z Was używa w pracy #akka #spray lub #playframework podejścia #reactiveprogramming ?

Może coś innego od #typesafe ?

http://www.reactivemanifesto.org/

http://www.reactive-streams.org/
2

Powiązane tagi