FP-TS 分支（面向铁路的编程）

Question

我在尝试使用 FP-TS 实现事物时不断遇到的一种模式是，当我的管道涉及到 TaskEither 的分支和合并分支时。

合并似乎工作得很好，因为我可以使用sequenceT创建数组并将它们通过管道传输到函数中，然后使用所有这些值。

似乎不太有效的是更复杂的依赖关系图，其中一个函数需要较早的项目，然后需要该函数的输出以及第一个任务的原始结果。

基本上像这样的函数签名（这可能不是 100% 正确的类型，但了解其要点）：

function fetchDataA(): TaskEither<Error, TypeA> {
}

function fetchBBasedOnOutputOfA(a: TypeA): TaskEither<Error, TypeB> {
}

function fetchCBasedOnOutputOfAandB(a: TypeA, b: TypeB): TaskEither<Error, TypeC> {
}

因为在管道中，你可以很好地为前两个作曲

pipe(
  fetchDataA(),
  TE.map(fetchBBasedOnOutputOfA)
)

这个管道按预期返回 TaskEither<Error, TypeB> ，并且地图处理错误对我来说很好。

而要执行最后一个操作，我现在需要输入 TypeA 作为参数，但它不可用，因为它已传递到 B 中。

一种解决方案是让函数 B 同时输出 A 和 B，但这感觉不对，因为创建 B 的函数不必知道其他某个函数也需要 A。

另一种方法是创建某种中间函数来存储 A 的值，但在我看来，这破坏了使用 TaskEither 的全部意义，即我要抽象出所有错误类型并自动处理它。

我会有某种奇怪的功能：

async function buildC(a : TypeA): TaskEither<Error, TypeC> {
  const b = await fetchBBasedOnOutputOfA(a);
  // NOW DO MY OWN ERROR HANDLING HERE :(
  if (isRight(b)) {
    return fetchCBasedOnOutputOfAandB(a, b);
  }
  // etc.

那么有没有更惯用的方法来做到这一点，也许创建树结构并遍历它们？尽管说实话，Traverse 的文档中的代码示例非常稀疏，而且我不知道如何使用它们。

Answer 1

我想说有两种惯用的写法：

1. 使用嵌套调用chain：

pipe(
  fetchDataA(),
  TE.chain(a => { // capture `a` here
    return pipe(
      fetchBBasedOnOutputOfA(a), // use `a` to get `b`
      TE.chain(b => fetchCBasedOnOutputOfAandB(a, b)) // use `a` and `b` to get `c`
    )
  })
)

2. 使用Do表示法：fp-ts公开“do”语法，可以减轻 的过度嵌套chain，特别是当您需要捕获稍后在程序流的不同部分中重用的大量值时。

pipe(
  // begin the `do` notation
  TE.Do,
  // bind the first result to a variable `a`
  TE.bind('a', fetchDataA),
  // use your `a` to get your second result, and bind that to the variable `b`
  TE.bind('b', ({ a }) => fetchBBasedOnOutputOfA(a)),
  // finally, use `a` and `b` to get your third result, and return it
  TE.chain(({ a, b }) => fetchCBasedOnOutputOfAandB(a, b))
);

您可以在此处查看 Do 表示法的语法。