前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Combine-Future

Combine-Future

作者头像
YungFan
发布2020-05-20 17:26:27
7970
发布2020-05-20 17:26:27
举报
文章被收录于专栏:学海无涯

前面我们用过Just,其数据的发布和订阅是同步行为。如果希望数据的发布和订阅是异步的,可以使用FutureFuture可以创建一个接收未来数据与事件的 Publisher。Future定义如下:

代码语言:swift
复制
final public class Future<Output, Failure> : Publisher where Failure : Error {

    public typealias Promise = (Result<Output, Failure>) -> Void
    
    public init(_ attemptToFulfill: @escaping (@escaping Future<Output, Failure>.Promise) -> Void)
    
    final public func receive<S>(subscriber: S) where Output == S.Input, Failure == S.Failure, S : Subscriber
}
  • Future 是一次性的且非 lazy 的,它会在初始化时立刻执行闭包,需要存储处理 Promise 中的值,发给当前和未来的一个或多个 Subscriber。一旦产生一个数据或失败时,Future 会立即结束。
  • Future 适用于那些必然会产生事件结果且至多只会产生一个结果的场景。

Promise

从上面的定义可以看出,其本质是(Result<Output, Failure>) -> Void的类型别名,它表示 Future 的最终结果。

成功的处理

代码语言:swift
复制
import UIKit
import Combine

let future = Future<Int, Never> { promise in
    
    DispatchQueue.main.asyncAfter(deadline: .now() + 3) {
        promise(.success(100))
    }
}

let subscription = future.sink(receiveValue: { value in
    print(value)
})

失败的处理

代码语言:swift
复制
import UIKit
import Combine

struct SomeError: Error {
}

let future = Future<Int, SomeError> { promise in
    
    DispatchQueue.main.asyncAfter(deadline: .now() + 3) {
        promise(.failure(SomeError()))
    }
}

let subscription = future.sink(receiveCompletion: { completion in
    if case .failure(let error) = completion {
        // 失败的处理
        print(error)
    }
}, receiveValue: { _ in
    // 成功的处理
})

基本使用

代码语言:swift
复制
import Combine

// 返回一个Future对象且会产生一个Int类型的值
func createFuture() -> Future<Int, Never> {
    // 返回一个Future,它是一个闭包
    // 在该闭包里执行异步操作,只会执行一次
    return Future { promise in
        // 异步操作
        
        // 最后必须调用promise完成工作
        promise(.success(100))
    }
}

createFuture().sink(receiveValue: { value in
    print(value)
})

/*输出
 100
 */

说明

  1. 当创建一个 Future 时,它会立即开始执行。
  2. Future 将只运行一次提供的闭包。
  3. 多次订阅同一个 Future 将返回同一个结果。
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • Promise
    • 成功的处理
      • 失败的处理
      • 基本使用
        • 说明
        领券
        问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档