Результаты поиска по запросу "rx-java"
может быть передан для получения дополнительной информации.
у сделать что-то после небольшой задержки: public void notifyMe() { Single .timer(500, TimeUnit.MILLISECONDS) .subscribeOn(Schedulers.io()) .subscribe(ignore -> service.notifyMe())); }Теперь у меня есть предупреждение:"The result of subscribe is ...
Я только что видел это! Посмотрим позже.
аюсь получить снимок GoogleMap (из MapView) в фоновом режиме, вернуть его с обратным вызовом и показать его в ImageView. При этом я стараюсь сделать получение снимка как можно более независимым от макета (поэтому стараюсь не добавлять MapView в ...
вызовет новый буфер с самым первым пустым буфером.
я есть наблюдаемая, которая излучает большое количество данных, таких как [1,1,1,2,2,2,3,3,1,1,5,5 ......] В RxJava мы можем использоватьdistinctUntilChanged () [http://reactivex.io/documentation/operators/distinct.html]чтобы получить отдельные ...
может быть полезным (по крайней мере, первые 15 минут)
ользую RxJava для обработки некоторых уведомлений, которые мы извлекаем из очереди. Казалось, что RxJava отлично работает с простым рабочим процессом, теперь, когда появляются новые требования, этот процесс усложняется с появлением ...
RxJava - прекращение бесконечных потоков
Я изучаю реактивное программирование и RxJava. Это весело, но я застрял на проблеме, на которую не могу найти ответ. Мой основной вопрос: что такое реактивно-подходящий способ прекратить бесконечно запущенную Наблюдаемую? Я также приветствую ...
Как можно отписаться от PublishSubject и BehaviorSubject?
Подsubjects Пакет у вас есть классы, какPublishSubject а такжеBehaviorSubject который, я полагаю, может быть описан как полезный образецObservables. Как можно отписаться от этих тем? Здесь нетunsubscribe метод и вызовonCompleted Заканчивает ...