在 Combine 中，我如何按顺序运行一系列期货？

Question

是否有一个 Combine 运算符可以按顺序运行一系列期货，在开始下一个之前运行每个期货？

我可以用非常凌乱的方式做到这一点：

f1
.flatMap { _ in 
  f2
}.flatMap { _ in 
  f3
}.flatMap { _ in 
  // ... 
}

但我更喜欢这样的：

sequence(f1, f2, f3, ...)

在某些框架中，这看起来像：

f1.then { f2 }.then { f3 }

Answer 1

关键是将 Future 包装在 Deferred 中，这样它就不会执行，直到它的时间：

let f1 = Deferred { Future<Int, Error> { result in

    }
}
let f2 = Deferred { Future<Int, Error> { result in

    }
}
let f3 = Deferred { Future<Int, Error> { result in

    }
}
let jobs = f1
    .append(f2)
    .append(f3)

cancellable = jobs.sink(receiveCompletion: { (completion) in
    print("all three jobs done or one errored.")
}, receiveValue: { value in
    print("value of job:", value)
})

---

回答 cmets 中的其他问题：

你不能依赖 Deferred 来推迟闭包的执行，直到订阅者进来，因为 Deferred 是一个结构体，每次有新订阅者时都会创建一个新的 Future。

这正是延迟的意义所在。每次有新订阅者时创建一个新的未来，而不是在那之前。另一种选择是在追加中创建期货。

let jobs = Future<Int, Error> { result in }
    .append(Future<Int, Error> { result in })
    .append(Future<Int, Error> { result in })

但是所有三个期货将同时执行它们的代码。我假设你不想要这个。