我需要调用一系列函数来获取通知所需的所有信息。首先订阅打开会话,然后queryNotification监听所有传入的通知,一旦收到通知,需要用getNotificationAttrs中返回的notificationId调用queryNotification,然后用getAppAttributes中返回的appIdentifier调用getNotificationAttrs,我需要queryNotificationgetNotificationAttrsgetAppAttributes的组合结果。功能如下:

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返回可观测,并且getNotificationAttrsgetAppAttributes都返回单个。我想把他们绑在一起是这样的:
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
            }
       })

这可行吗?任何方向都是值得赞赏的!谢谢!

最佳答案

最明显也是最正确的解决方案是将您的Single提升为Observable。而且,我也不是第一个粉丝。你最终得到了一个缩进金字塔。
我正按照您的意见,需要所有subscribequeryNotification()getNotificationAttrs(did: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

    })

上面的步骤将遵循您概述的步骤,每次发出新通知时都将调用subscribe。
还要注意上面的代码读起来有点像同步代码(只是有一些额外的包装)。

关于swift - RxSwift-链接可观察对象和单打,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/54834452/

10-09 22:52