reactivex

2зной

1ответ

ReactiveX: рассчитать частоту отдельных элементов в наблюдаемом

У меня есть Observable<String>. Я хотел бы превратить это в Map<String, Int>, который сообщает мне количество вхождений для каждой отдельной строки. Наблюдаемый содержит ~ 1 миллиард элементов, из кот

java scala reactive-programming rx-java reactivex 2015-11-24

---

4зной

2ответ

группеПо, фильтр и утечка памяти в Rx

В соответствии с документацией groupBy: Примечание: GroupedObservable будет кэшировать элементы это не испускать до тех пор, пока он подписан. По этой причине, чтобы избежать утечек памяти, вы не долж

java memory-leaks reactive-programming rx-java reactivex 2015-11-25

---

4зной

2ответ

ReactiveX: Group и Buffer только последний элемент в каждой группе

Как сгруппировать наблюдаемое, и из каждого GroupedObservable сохранить в памяти только последний испущенный элемент? Чтобы каждая группа вела себя так же, как BehaviorSubject. Что-то вроде этого: {us

javascript rxjs reactivex 2015-12-08

---

0зной

1ответ

Отменить задание в reactivex.net

Принято считать, что я существовал подобный код: public IEnumerable<DataType> GetAllData(string[] ids) { foreach(var id in ids) { //this is a time-consuming operation, like query from datab

c# reactivex 2015-12-08

---