reactive-programming

7Ciepło

1Odpowiedz

Jak radzić sobie z błędami podczas wykonywania Flux.map()

Próbuję dowiedzieć się, jak błędy obsługi podczas mapowania elementów wewnątrz strumienia. Na przykład, jestem parsowania ciąg CSV do jednego z moich POJOs biznesowych: myflux.map(stock -> converter.c

java reactive-programming project-reactor 2016-03-26

---

5Ciepło

2Odpowiedz

Używanie RxJava do sprawdzania poprawności logowania przez e-mail, obserwowalny emituje dwa razy

Tworzę prosty formularz logowania (e-mail i hasło), aby wzmocnić mój zestaw umiejętności programowania reaktywnego. Mam problem z uzyskaniem sprawdzania poprawności adresu e-mail, aby działał tak, jak

java android functional-programming rx-java reactive-programming 2016-02-09

---

5Ciepło

1Odpowiedz

kątowa 2 AsynPipe nie działa z obserwowalnych

Dostaję następujący błąd: EXCEPTION: Cannot find a differ supporting object '[object Object]' in [files | async in [email protected]:9] Oto odpowiednia część szablonu: <img *ngFor="#file of files |

javascript angular reactive-programming rxjs observable 2016-04-18

---

8Ciepło

1Odpowiedz

Różnica między programowaniem obiektowym a programowaniem reaktywnym

Posiadam sporą wiedzę o programowaniu obiektowym i bardzo słabo rozumiem programowanie reaktywne. Czy ktoś może wyjaśnić różnicę między programowaniem obiektowym a programowaniem reaktywnym?

oop reactive-programming 2016-03-09

---

5Ciepło

1Odpowiedz

Synchroniczny strumień odpowiedzi ze strumienia żądań z RxJS

Jestem nowy w RxJS i zastanawiałem się, czy ktoś mógłby mi pomóc. Chcę utworzyć synchroniczny strumień odpowiedzi (najlepiej z odpowiednimi żądaniami) ze strumienia żądań (dane ładunku). Po prostu chc

javascript reactive-programming rxjs 2016-02-03

---

7Ciepło

2Odpowiedz

W jaki sposób wykorzystywane są strumienie reaktywne używane w programie Slick do wstawiania danych?

W przykładach korzystania ze strumieni reaktywnych przedstawiono tylko dane do odczytu w charakterze DatabasePublisher. Ale co się dzieje, gdy chcesz używać bazy danych jako Zlewu i zwrotu wstecznego

mysql slick reactive-programming slick-3.0 akka-stream 2016-04-04

---

6Ciepło

2Odpowiedz

Emituj następną wartość ze źródła Obserwowalne, gdy inny obserwowalny, powiadamiający, emituje

Spodziewam się, że moja sprawa jest powszechna, ale nie może znaleźć niczego odpowiedniego. Co chcę osiągnąć w Angular2/RxJS 5 to: source: ---1--2--3--4---------5--------6-|--> notifier: -o----------

angular reactive-programming rxjs rxjs5 2016-05-31

---

7Ciepło

1Odpowiedz

wycofywania transakcji w reaktywnym aplikacji

używam RxJava 1.1 komponować zauważalnego sekwencję od wewnątrz aplikacji wiosennym że wygląda następująco: @Transaction public Observable<Event> create(Event event) { return Observable.just(eve

java spring transactions rx-java reactive-programming 2016-03-08

---

7Ciepło

3Odpowiedz

Zdobądź najnowszą wartość obserwowalnej i emituj ją w sposób niezawodny.

Próbuję uzyskać najnowszą wartość danego Observable i sprawić, że natychmiast wyemituje po jej wywołaniu. Ze względu na kod poniżej jako przykład: return Observable.just(myObservable.last()) .fla

rx-java reactive-programming rx-android 2016-05-03

---

5Ciepło

3Odpowiedz

Jak zablokować wątek, aby czekać na odpowiedź w pliku vert.x?

Mam sytuacji gdzie mam zadzwonić do zewnętrznego interfejsu API A i wykorzystanie jej odpowiedź karmić się wniosek API B i nazwać, a następnie powrócić do odpowiedzi wywołującego API A. coś takiego ja

java reactive-programming vert.x event-driven 2016-05-13

---