reactivex

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

У меня есть поток, который испускает страницы данных A, B, C, D.... Какой оператор я могу использовать, чтобы получить такой поток: [A], [A, B], [A, B, C], [A, B, C, D]...? Я знаю collect или toList, но они испускают только один раз в конце потока....

Фон У меня есть ряд наблюдаемых объектов RxJava (либо генерируемых из клиентов Джерси, либо заглушек с использованием Observable.just(someObject)). Все они должны излучать ровно одно значение. У меня есть компонентный тест, который высмеивает всех клиентов Jersey и использует Observable.just(someObject), и ...

в настоящее время я приступаю к работе с платформой реактивных расширений для .NET, и я работаю над различными ресурсами введения, которые я нашел (в основном http://www.introtorx.com) наше приложение включает в себя ряд аппаратных интерфейсов, которые обнаруживают сетевые кадры, это будут мои IObservables, ...