swift - RxSwift - 链接 Observables 和 Singles

Question

我需要调用一系列函数来获取通知所需的所有信息。首先订阅打开 session ，然后 queryNotification监听所有传入的通知，一旦收到通知，需要调用 getNotificationAttrs与 notificationId返回 queryNotification , 然后调用 getAppAttributes与 appIdentifier返回 getNotificationAttrs我需要 queryNotification 的组合结果, getNotificationAttrs和 getAppAttributes .这些函数的外观如下:

func subscribeNotification() -> Single<Info>
func queryNotification() -> Observable<Notification>
func getNotificationAttrs(uid: UInt32, attributes: [Attribute]) -> Single<NotificationAttributes>
func getAppAttributes(appIdentifier: String, attributes: [AppAttribute]) -> Single<NotificationAppAttributes>

棘手的部分是 queryNotification返回 Observable 和 getNotificationAttrs和 getAppAttributes返回单。我想将它们链接在一起的想法是:

subscribeNotification()
    .subscribe(onSuccess: { info in
        queryNotification()
            .flatMap({ notification in 
                return getNotificationAttributes(uid: notification.uid, attributes: [.appIdentifier, .content])
            })
            .flatMap({ notifAttrs
                return getAppAttributes(appIdentifier: notifAttrs.appIdentifier, attributes: [.displayName])
            })
            .subscribe {
                // have all the result from last two calls
            }
       })

这可行吗？任何方向表示赞赏!谢谢!

Answer 1

最明显和恕我直言的正确解决方案是将您的 Single 提升为 Observable。另外，我不喜欢它所在的第一个 subscribe。您最终会得到一个缩进金字塔。

我正在关注您关于需要所有 queryNotification()、getNotificationAttrs(did:attributes:) 和 getAppAttributes(appIdentifier:attributes) 的值的评论:)...

let query = subscribeNotification()
    .asObservable()
    .flatMap { _ in queryNotification() }
    .share(replay: 1)

let attributes = query
    .flatMap { getNotificationAttrs(uid: $0.uid, attributes: [.appIdentifier, .content]) }
    .share(replay: 1)

let appAttributes = attributes
    .flatMap { getAppAttributes(appIdentifier: $0.appIdentifier, attributes: [.displayName]) }

Observable.zip(query, attributes, appAttributes)
    .subscribe(onNext: { (query, attributes, appAttributes) in

    })

以上内容将按照您概述的步骤进行，每次发出新通知时都会调用订阅。

另请注意，上面的代码读起来有点像同步代码(只是有一些额外的包装。)