Описание тега reactivex
ReactiveX - это библиотека для создания асинхронных программ и программ, основанных на событиях, с использованием наблюдаемых последовательностей.
1
ответ
Интервал rxjava в сочетании с другим наблюдаемым
У меня есть наблюдаемое (что горячо), которое делает что-то через системный процесс, и я бы хотел, чтобы интервал также работал, пока наблюдаемый процесс не достигнет полного завершения. Я вижу оператор интервала: http://reactivex.io/documentation/o…
20 мар '17 в 17:42
1
ответ
RxSwift: повторить (завершено) поток
Предположим, у меня есть кнопка, которую можно использовать для запуска и остановки (переключения) действия. let toggleStream: Observable<Bool> = toggleBtn.rx.tap.scan(false) { state, _ in !state } У меня есть другой поток, который непрерывно …
26 апр '17 в 22:18
1
ответ
RxJs: шаблон для наблюдаемых результатов поиска
Мой сценарий - это классическая веб-страница с формой поиска и списком результатов. Я хочу инкапсулировать поведение загрузки результатов в Observable. Вот что я сейчас делаю в TypeScript: function loadResults(query): Observable<T[]> {} const …
16 дек '17 в 12:07
0
ответов
rxpy: buffer_with_time со случайным джиттером?
Я использую buffer_with_time, он принимает аргумент ключевого слова: timespan – Length of each buffer (specified as an integer denoting milliseconds) Тем не менее, отметка времени является фиксированной. Я хочу добавить к нему случайный джиттер. Есл…
17 янв '18 в 03:45
2
ответа
Почему не вызывается doOnNext()?
Ни onNext(), ни onCompleted() не будут вызваны для моего подписчика ниже. Я попытался реализовать подписчика с помощью doOnNext()/doOnTerminate(). Я также попытался сделать doAfterTerminate(). Я также попытался явно определить подписчика, и ни onNex…
29 апр '17 в 03:18
1
ответ
RxSwift TestScheduler не работает, если подписаться на фоне
У меня есть фиктивный интерактор и маршрутизатор для модульных тестов по методике презентатора: private func presenterMethod(_ isOn: Bool) -> Driver<Bool> { return interactor.interactorMethod(isOn) .subscribeOn(ConcurrentDispatchQueueSchedu…
25 ноя '18 в 15:18
2
ответа
Вопрос о пользовательском расширении RxSwift Observable
extension Observable { func dispatchAsyncMainScheduler() -> Observable<E> { return self.observeOn(backgroundScheduler).observeOn(MainScheduler.instance) } } Я нашел этот фрагмент в https://github.com/artsy/eidolon Я reactive начинающий здес…
18 фев '19 в 10:33
2
ответа
ReactiveX: группа и буфер только последний элемент в каждой группе
Как сгруппировать Observable и из каждого GroupedObservable сохранить в памяти только последний отправленный элемент? Так что каждая группа будет вести себя так же, как BehaviorSubject. Что-то вроде этого: {user: 1, msg: "Anyone here?"} {user: 2, ms…
08 дек '15 в 00:21
0
ответов
Оператор RxJava, который динамически буферизует элементы с обратным давлением и генерирует их пакетами
У меня есть Flowable, который испускает события, которые должны быть обработаны дорогой операцией, которая ожидает массивы элементов: Flowable<T> src void expensiveOp(List<T> batch) Помимо использования постоянного окна, я хотел бы указа…
14 ноя '18 в 15:09
1
ответ
RxSwift с последним из странного поведения
Сегодня я переносил свой код из ReactiveSwift в RxSwift и пришел к этому странному сценарию. у меня есть Observable состоит из withLatestFrom оператор внутри ViewModel класс, и он излучает только на тестовую подписку, которую я сделал внутри инициал…
09 окт '18 в 12:43
1
ответ
RxSwift: предотвращение нескольких сетевых запросов
В настоящее время у меня возникает проблема с несколькими сетевыми запросами, выполняемыми при использовании RxSwift Observables. Я понимаю, что если создать холодную наблюдаемую область и иметь несколько наблюдателей, она будет выполнять свой блок …
16 янв '17 в 16:49
5
ответов
Почему темы не рекомендуются в.NET Reactive Extensions?
В настоящее время я знакомлюсь с платформой Reactive Extensions для.NET и прорабатываю различные вводные ресурсы, которые я нашел (в основном http://www.introtorx.com/) Наше приложение включает в себя несколько аппаратных интерфейсов, которые обнару…
18 янв '13 в 10:01
0
ответов
Angular2 HTTP сообщение возвращает ErrorObservable
Когда я использую map(res => res.text()) Я получаю эту ошибку: Нет лучшего распространенного типа среди возвращаемых выражений. Это работает, когда я использую map(res => res.json()), Это моя функция: public register(credentials) { if (credent…
09 фев '17 в 17:32
1
ответ
ReactiveX, как приостановить наблюдаемое
Я использую ReactiveX в iOS / Swift ( RxSwift). Допустим, у меня есть наблюдаемое: let dataUpdates = ... На что я подписан: dataUpdates.subscribeNext({ data in // update tableView with data // maybe move to a difference cell with an animation }) Есл…
25 май '16 в 18:59
2
ответа
RxJS определяет, когда наблюдаемые подписаны на
У меня есть необходимость обнаружить, когда наблюдаемый (observedEvents) была подписана, подписаться на другую заметную (triggerEvent). Я не хочу подписываться на triggerEvent вручную, но только один раз и когда observedEvents имеет подписку. Вот ко…
14 июн '17 в 22:20
2
ответа
Каковы различия в реализации Schedulers.computation и Schedulers.io?
Почему они используются для разных задач? Что отличает их при обработке вычислительной задачи против задачи io? Schedulers.computation () - предназначен для вычислительной работы, такой как циклы обработки событий и обработка обратных вызовов; не ис…
08 апр '16 в 14:20
1
ответ
Излучение пунктов прогресса при пересылке приводит к единственной наблюдаемой
Я инициирую операцию через REST API в два этапа: Начать работу и вернуть идентификатор задачи Опросите задание с заданным идентификатором и завершите последовательность, когда операция завершится. Опрос идентификатора задачи вернет 202, который указ…
19 янв '18 в 20:04
2
ответа
Реактивный повторный пропуск между
Предположим, у меня есть следующий поток данных: 1, 2, 3, a, 5, 6, b, 7, 8, a, 10, 11, b, 12, 13, ... Я хочу фильтровать все между "а" и "б" (включительно), независимо от того, сколько раз они появляются. Таким образом, результат выше будет: 1, 2, 3…
28 май '17 в 17:38
1
ответ
RxSwift throttle(), чтобы получить первый элемент
Я ищу способ, которым throttle() Оператор отказывается от первого элемента в Observable в течение определенного промежутка времени, а не последний элемент. Аналогичный вопрос был задан (и получен ответ) в RxSwift - Debounce / Throttle "inverse", но …
02 окт '16 в 02:16
1
ответ
Идеи пагинации для Angular2 и ReactiveX
Я учу ReactiveX. Я обрезал проверку ошибок, ведение журнала и другие биты, чтобы их было легче читать. У меня есть сервис, который возвращает коллекцию объектов в виде JSON: getPanels() { return this.http.get(this._getPanelsUrl) .map(panels => &l…
25 фев '16 в 20:59