Вопросы по теме 'reactivex'
Концепция массива в Reactivex
Привет, я начинаю использовать ReactiveX c#, все звучит хорошо, за исключением концепции.
Я не знаю, как сделать реактивный массив (или коллекцию или список)
Я хотел бы иметь что-то вроде ObservableCollection, но с концепцией реактивности. Я бы...
74 просмотров
schedule
10.03.2023
передать работу наблюдателям
У меня есть слушатель, который получает работу в виде IPayload. Слушатель должен передать эту работу наблюдателям, которые действительно выполняют эту работу. Это моя первая грубая попытка добиться этого:
public interface IObserver
{
void...
164 просмотров
schedule
17.03.2023
Обходные пути для сбоев RX?
Я экспериментирую с Reactive Extensions на разных платформах, и одна вещь, которая меня немного раздражает, — это глюки.
Хотя для кода пользовательского интерфейса эти сбои могут не вызывать таких проблем , и обычно можно найти оператора, который...
429 просмотров
schedule
07.01.2023
RXJS: агрегированный дребезг
Мой пример использования следующий: я получаю события, которые иногда происходят всплесками. Если происходит всплеск, мне нужно обработать его только один раз. Debounce делает это.
Однако debounce дает мне только последний элемент пакета, но мне...
4039 просмотров
schedule
28.05.2023
Таймер самоотмены ReactiveX
Я хочу создать метод расширения формы:
IObservable<bool> CancellableTimer( this IObservable source, TimeSpan delay )
{
...
}
который создает последовательность, которая всегда ложна, когда исходная последовательность является истинной,...
32 просмотров
schedule
05.01.2023
rxcpp — почему функция on_next всех наблюдателей не вызывается, когда наблюдаемое испускает значение
Я пытаюсь понять, как использовать rxcpp, у меня сложилось впечатление, что когда наблюдаемый объект испускает значение, все подписанные наблюдатели будут получать уведомления, вызывая свои методы on_next(), передавая им испускаемое значение.
Это...
494 просмотров
schedule
27.09.2022
Наблюдение за UITextField.editing с помощью RxSwift
Я хочу наблюдать за свойством UITextfield.editing . Я использую этот код:
self.money.rx_observe(Bool.self, "editing").subscribeNext { (value) in
print("")
}.addDisposableTo(disposeBag)
Но в процессе работы он выполняется только один...
23806 просмотров
schedule
08.01.2024
RxSwift Throttle() для получения первого элемента
Я ищу способ, которым оператор throttle() отказывается от первого элемента в Observable в течение заданного интервала времени, а не от последнего элемента.
Аналогичный вопрос был задан (и дан ответ) в RxSwift - Debounce/Throttle inverse , но...
1437 просмотров
schedule
29.12.2023
RxSwift — .subscribe и .subscribeNext в чем разница?
В чем разница между этими двумя операторами? http://reactivex.io вообще не упоминайте .subscribeNext.
2438 просмотров
schedule
17.08.2022
RxPy читает файлы csv и строки процесса
Я хочу использовать RxPy для открытия файла (csv) и обработки файла построчно. Я точно предполагаю следующие шаги
указать имя файла для потока
открыть файл
читать файл построчно
удалить строки, начинающиеся с комментария (например, # ...)...
778 просмотров
schedule
16.12.2022
Можно ли вызывать методы расширения Rx с помощью лямбда-выражений из скрипта IronPython?
Может кто-нибудь объяснить мне это действительно странное наблюдение?
Я пытался вызывать методы расширения Rx изнутри IronPython, и это оказалось просто невозможным. Я свел это к этому простому примеру:
import clr...
127 просмотров
schedule
31.01.2023
Оператор Rx, который начинается как combLatest, но затем действует как withLatestFrom
Я ищу оператор, который объединяет два Observables , не генерируя ничего, пока оба Observables не испустят элемент (аналогично combineLatest ), но затем излучает элементы только путем объединения элементов из одного Observable с последним...
717 просмотров
schedule
18.06.2023
Циклические зависимости между потоками в реактивном программировании
Занимаясь реактивным программированием, я часто сталкиваюсь с ситуациями, когда два потока зависят друг от друга. Каков идиоматический способ решения этих случаев?
Минимальный пример: есть кнопки A и B, обе отображают значение. Нажатие на A...
188 просмотров
schedule
04.10.2022
RxSwift: как передать событие управления через несколько моделей представления
У меня есть ячейка представления коллекции с кнопкой, и я хочу передать событие управления касанием ( button.rx.rap ) через модель представления ячейки, через модель представления контроллера представления и в сам контроллер представления коллекции...
747 просмотров
schedule
29.10.2022
Асинхронная загрузка ячеек UITableView с помощью RxSwift
Я пытаюсь использовать RxSwift в своем приложении. Один из вариантов использования - это асинхронная загрузка изображения UITableView, которая запускается кнопкой поиска (или перезапуском ячейки). Что я не могу заставить работать хорошо, так это...
1049 просмотров
schedule
14.03.2022
Java-процесс ReactiveX завершается раньше?
public class ReactiveExample {
public static void main(String[] args) throws InterruptedException, NumberFormatException, UnsupportedEncodingException {
Observable.range(1, 5).subscribe(
System.out::println,...
23 просмотров
schedule
15.12.2022
Почему параллельное выполнение не происходит для нескольких наблюдаемых RXJava?
Я новичок в RxJava и пытался выполнить пример параллельного выполнения для нескольких Observables по ссылке: Параллельная выборка RxJava Observable
Хотя пример, приведенный в приведенной выше ссылке, выполняет наблюдаемые параллельно, но когда я...
269 просмотров
schedule
14.08.2022
В поисках лучших способов компоновки RxJava Observables
Я разрабатываю инструмент, который собирает данные из нескольких источников и последовательно применяет несколько преобразований. В настоящее время я конвертирую эту функциональность из потоков Java 8 для использования ReactiveX/RxJava.
Ниже вы...
306 просмотров
schedule
27.11.2022
Как объединить список Завершаемых задач в один Завершаемый результат?
У меня есть метод, который возвращает Single<List<Item>> , и я хотел бы взять каждый элемент в этом списке и передать его нижестоящему методу, который возвращает Completable . Я хочу дождаться успешного завершения каждого элемента и...
2421 просмотров
schedule
06.09.2022
Как сгруппировать элементы в группы размера n в RxJs 5?
Мне нужна помощь, чтобы сгруппировать элементы в бесконечном потоке без потери данных.
Размер групп не должен превышать n элементов. Если в течение какого-то времени не приходило ни одного товара, то размер текущей группы может быть меньше n....
224 просмотров
schedule
10.08.2022
