使用Observable RxSwift中的'asPromise ()'可以在PromiseKit Promise中使用吗？

Question

我编写函数"asPromise((">

extension PrimitiveSequence {
public func asPromise() -> Promise<Element> {
var disposed: Disposable? = nil
return Promise<Element> { seal in
disposed = self.asObservable()
.subscribe { event in
switch event {
case .next(let element):
seal.fulfill(element)
case .error(let error):
seal.reject(error)
case .completed:
disposed?.dispose()
}
}
}
}}

但处置很奇怪，我不知道该怎么办。所以如果你有更好的想法，请告诉我

谢谢

Answer 1

根本不需要捕获一次性的。当Observable完成时，它将自动处理所有资源。以下是正确的实现：

extension PrimitiveSequence where Trait == SingleTrait { // will only work properly for Singles
public func asPromise() -> Promise<Element> {
Promise<Element> { seal in
_ = subscribe { event in
switch event {
case let .success(element):
seal.fulfill(element)
case let .failure(error):
seal.reject(error)
}
}
}
}
}

您知道Combine API已经内置了类似Promise的类型吗？

extension PrimitiveSequence where Trait == SingleTrait {
public func asFuture() -> Future<Element, Error> {
Future { fulfill in
_ = self.subscribe(fulfill)
}
}
}