我需要调用一系列函数来获取通知所需的所有信息。首先订阅打开会话,然后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
返回可观测,并且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
}
})
这可行吗?任何方向都是值得赞赏的!谢谢!
最佳答案
最明显也是最正确的解决方案是将您的Single
提升为Observable
。而且,我也不是第一个粉丝。你最终得到了一个缩进金字塔。
我正按照您的意见,需要所有subscribe
、queryNotification()
和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/