在Observable RxSwift中使用‘asPromise()’可以在PromiseKit Promise中使用吗？

Question

我写了函数'asPromise()'

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

谢谢你

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)
        }
    }
}