Объединение двух наблюдателей уведомлений в RxSwift

У меня есть этот фрагмент кода:

let appActiveNotifications: [Observable<NSNotification>] = [
    NSNotificationCenter.defaultCenter().rx_notification(UIApplicationWillEnterForegroundNotification),
    NSNotificationCenter.defaultCenter().rx_notification(Constants.AppRuntimeCallIncomingNotification)
]

appActiveNotifications.merge()
  .takeUntil(self.rx_deallocated)
  .subscribeNext() { [weak self] _ in
  // notification handling
}
.addDisposableTo(disposeBag)

Предполагается, что он прослушивает любое из указанных уведомлений и обрабатывает их при срабатывании.

Однако это не компилируется. Я получаю следующую ошибку:

Value of type '[Observable<NSNotification>]' has no member 'merge'

Как мне тогда объединить эти два сигнала в один?


swift rx-swift reactivex
person Milan Cermak    schedule 01.04.2016    source источник

Ответы (1)


arrow_upward
26
arrow_downward

.merge() объединяет несколько Observables, поэтому вам нужно сделать appActiveNotifications.toObservable(), а затем вызвать .merge()

Изменить: Или как пример в площадка RxSwift, вы можете использовать Observable.of(), а затем использовать .merge() на ней; вот так:

let a = NSNotificationCenter.defaultCenter().rx_notification(UIApplicationWillEnterForegroundNotification)
let b = NSNotificationCenter.defaultCenter().rx_notification(Constants.AppRuntimeCallIncomingNotification)

Observable.of(a, b)
  .merge()
  .takeUntil(self.rx_deallocated)
  .subscribeNext() { [weak self] _ in
     // notification handling
  }.addDisposableTo(disposeBag)
person David Chavez    schedule 01.04.2016
comment
Я хочу объединить 2 разных типа наблюдателей. Есть идеи, как этого добиться? Это то, что я пытаюсь сделать. stackoverflow.com/questions/39050059/ - person Swift Hipster; 20.08.2016
comment
Вы не можете объединить 2 разных типа Observables. Вы должны конвертировать одну из них или обе, чтобы найти совпадение! - person nverinaud; 08.12.2016
comment
@SwiftHipster, вы можете использовать zip, чтобы получить оба результата и объединить их вручную. - person Daniel Gomez Rico; 28.02.2017
comment
если возможно, сопоставьте их с одним и тем же типом, например NSNotificationCenter.defaultCenter().rx_notification(UIApplicationWillEnterForegroundNotification).map({ _ in true}_ - person Shahar; 03.04.2017