Публикации по теме 'reactivex'
Другой подход к Rx: готовка с RxJS
Самые простые вещи часто труднее всего выучить. Наш опыт работы со сложными темами мешает нам переключить наш мозг на понимание простых вещей.
И нет, шарики не всегда помогают. Вы можете найти гораздо лучшие метафоры, некоторые из них даже в вашем собственном холодильнике.
Вы, наверное, уже слышали о реактивном программировании. Есть вероятность, что вы использовали ReactiveX в своем любимом языке программирования. И скорее всего, вы, вероятно, боролись с этим вначале, как..
Обзор ReactiveX (RxJS)
ReactiveX — это полиглотная библиотека, позволяющая создавать асинхронные и событийные программы с помощью коллектива под названием Observable.
Чтобы лучше понять Observables, вы должны быть знакомы с шаблоном Observer.
Паттерн Наблюдатель — это шаблон проектирования, в котором объект, называемый «субъектом», отслеживает своих наблюдателей, которые на него подписаны. Когда субъект обновляется, он уведомляет наблюдателей о любых изменениях состояния.
То, что ReactiveX добавляет к..
Функции RxJS (часть 4)
конкат
Это было весело. Поскольку я использую interval для настройки Observable, я получаю холодный . Поскольку мой мраморный компонент подписывается на переданный ему Observable, он создает новый интервал для каждой подписки. Каждый из моих шариков стрелял волей-неволей, а не правильно отображал пример, который я имел в виду. Чтобы справиться с этим, я воспользовался оператором под названием поделиться , который в этом случае разделял исходный интервал с каждой новой..
Вопросы по теме 'reactivex'
Не удается распечатать элементы наблюдаемых после группировки
Не могу понять, почему следующий код rxscala не работает должным образом:
import rx.lang.scala.Observable
object MyTest extends App {
case class ProjectEvent(projectName: String, description: String)
val projectEvents:...
84 просмотров
schedule
19.08.2022
Каковы различия в реализации Schedulers.computation и Schedulers.io?
Почему они используются для разных видов задач? Что отличает их при обработке вычислительной задачи по сравнению с задачей ввода-вывода?
Schedulers.computation() — предназначен для вычислительной работы, такой как циклы событий и обработка...
674 просмотров
schedule
29.05.2024
ReactiveX Retry с несколькими потребителями
Быстрый вопрос, потому что я чувствую, что должен что-то упустить. Я использую rxjs здесь, потому что это то, что у меня есть передо мной, это общий вопрос о реактивномX, я полагаю.
Скажем, у меня есть набор Observables, например:...
61 просмотров
schedule
22.05.2024
Условная цепочка наблюдаемых
Я хочу асинхронно извлекать данные через несколько REST API. Я использую Retrofit на Android с расширением rxJava, т.е. я выполняю любой запрос GET, подписавшись на Observable.
Как я уже сказал, у меня несколько исходных API, поэтому, когда первый...
207 просмотров
schedule
24.12.2023
RxJava: BehaviorSubject не получает последующие выбросы из источника Observable
У меня возникли проблемы с попыткой использовать BehaviorSubject (через RxRelay.BehaviorRelay ) для хранения самой последней эмиссии из непрерывного Observable .
Под «непрерывным» я подразумеваю, что источник Observable предназначен для...
769 просмотров
schedule
17.05.2024
Агрегируйте все испускаемые потоки и испускайте их сразу с помощью rxJava.
У меня есть поток, который выдает страницы данных A, B, C, D... . Какой оператор я могу использовать, чтобы получить такой поток: [A], [A, B], [A, B, C], [A, B, C, D]... ?
Я знаю collect или toList , но они испускаются только один раз в конце...
349 просмотров
schedule
06.10.2023
Сопоставьте ошибки с наблюдаемыми с помощью C # ReactiveX
У меня есть наблюдаемое MyObservable<Object> , которое может бросить CustomExceptions где
private class CustomException : Exception
Что я хочу сделать, так это преобразовать CustomExceptions в объекты и испустить их в новом...
381 просмотров
schedule
23.08.2022
Завершить цепочку Observable, когда одна из них ошибается
У меня есть цепочка комплементов Rx, которые я хочу запускать один за другим. Я использую concat() для этого, так как не хочу, чтобы все они запускались одновременно....
612 просмотров
schedule
22.04.2024
Как дождаться завершения параллельных потоков RxPy
Основываясь на этом отличном ответе SO , я могу получить несколько задач, работающих параллельно в RxPy, моя проблема в том, как вы дождетесь их завершения? Я знаю, что с помощью многопоточности я могу сделать .join() , но, похоже, такой...
2568 просмотров
schedule
25.08.2022
Оператор очереди для RxJS
Есть ли в RxJS оператор, который позволил бы мне буферизовать элементы и выпускать их один за другим всякий раз, когда срабатывает наблюдаемый сигнал? Вроде как bufferWhen, но вместо того, чтобы сбрасывать весь буфер для каждого сигнала, он будет...
3318 просмотров
schedule
26.06.2022
mergeMap не существует для наблюдаемого типа
Я пытаюсь использовать mergeMap в rxjs6 и получаю эту ошибку:
Property 'mergeMap' does not exist on type 'Observable<{}>'
Я пробовал import 'rxjs/add/operator/mergeMap'; , и это не работает.
Что я делаю не так?
import...
11618 просмотров
schedule
05.06.2024
Обработка ошибок RxJava без проглатывания ошибки
Я немного новичок в RxJava. Я пытаюсь выдать другой элемент, если onError() вызывается без потери ошибки (я все еще хочу, чтобы onError() вызывался для наблюдателя). но когда я реализую каждый из методов обработки ошибок, объявленных в документах...
84 просмотров
schedule
07.03.2024
Борьба с преобразованием кода java RxBle в Kotlin
В настоящее время я разрабатываю приложение для Android с Kotlin. Это мой первый опыт работы с этим языком программирования, и сейчас я изо всех сил пытаюсь перевести пример кода Java на Kotlin.
Я хочу реализовать ответ на этот вопрос в Котлине....
187 просмотров
schedule
09.06.2024
Какова реализация блочного паттерна для новичков во флаттере?
Я новый пользователь флаттера.
При использовании проекта с флаттером я всегда использовал только виджеты stateflue или виджеты без состояния.
Я недавно узнал о государственном управлении и исследовал его.
Было много методов или пакетов для...
203 просмотров
schedule
20.03.2024