Я пытаюсь заставить подписку автоматически отменять подписку, когда она выдает элемент. Базовая наблюдаемая создается следующим образом. public static Observable<RxBleConnection> setupConnection(RxBleDevice device,...

Допустим, у меня есть наблюдаемые A, B, C. Я должен прислушаться к изменению этих трех и изменить расчет. то есть при изменении значения любого из наблюдаемых мне нужно пересчитать с новым значением из настоящего и старым значением для остальных...

При использовании CombineLatest с IObservables разных типов в настоящее время я использую функцию выбора, которая просто передает кортеж, поэтому я могу использовать его в методе Subscribe. IObservable<bool> obsBool; IObservable<int?>...

Я использую Rxjs и хочу создать Observable из следующего шаблона (по порядку): получить параметры из paramMap $, затем ... на основе значения params получить оба (getData (): Observable, getCategories (): Observables) вместе, затем .......

Если вы попробуете этот код в Playgroud: import Combine import Foundation struct User { let name: String } private var subscriptions = Set<AnyCancellable>() var didAlreadyImportUsers = false var users = [User]() func importUsers()...

Я использую RxJava, работающий на устройстве Android. У меня есть 2 PublishSubjects, которые регулярно публикуют данные (строки), полученные от характеристик bluetooth через вызов OnNext(). Одна характеристика (А) определенно существует, другая (В)...