reactivex

0зной

1ответ

reactivex: взятие комбинации take и takeLast в виде функции окна

Я относительный новичок в ReactiveX и узнал о Rx.Observable.take и Rx.Observable.takeLast, чтобы взять из начала и конца последовательности соответственно и Rx.Observable.windowWithCount, чтобы сделат

0зной

2ответ

RxJS/ReactiveX Соответствующие модули связи

Я довольно новичок в области реактивного программирования, но уже влюблен. Однако мне все еще сложно переключить мой мозг. Я стараюсь следовать всем рекомендациям как «Избегайте использования предмето

0зной

1ответ

Многие наблюдатели подключен к одному наблюдаемым получать события по одному

Это, как я создаю мои наблюдаемый: Observable.fromCallable(new EventObtainer()).flatMap(Observable::from).subscribeOn(Schedulers.io()).repeat(); И после этого, через запрос HTTP я пытаюсь добавить р

1зной

1ответ

RxJava: BehaviorSubject, не получающий последующие выбросы от источника. Наблюдаемый

У меня возникли проблемы с попыткой использовать BehaviorSubject (через RxRelay.BehaviorRelay) для хранения самого последнего излучения от непрерывного Observable. Под «непрерывным» я имею в виду, что

1зной

1ответ

RxPy - Включите поток Live Twitter в Rx Observable?

Я следил за этим great tutorial, чтобы использовать прямой поток Twitter в Python, используя tweepy. Это будет печатать твиты в режиме реального времени, в которых упоминаются RxJava, RxPy, RxScala ил