sáp nhập hai nhà quan sát thông báo trong RxSwift

Question

Tôi có đoạn mã này:

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) 

Đó là nghĩa vụ phải lắng nghe một trong các thông báo cụ thể và xử lý khi ai trong số họ được kích hoạt.

Tuy nhiên điều này không biên dịch. Tôi nhận được lỗi sau:

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

Làm cách nào để hợp nhất hai tín hiệu này với một tín hiệu?

Answer 1

.merge() kết hợp nhiều Observables vì vậy bạn sẽ muốn làm appActiveNotifications.toObservable() sau đó gọi .merge() vào nó

Edit: Hoặc như ví dụ trong RxSwift's playground, bạn có thể sử dụng Observable.of() sau đó sử dụng .merge() vào nó; như vậy:

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)