fp-ts中TaskEither与Either管道组合的优雅实现问询

API 探路者

2026-7-22

解决方案

在fp-ts中，要将异步的TaskEither与同步的Either计算自然融合，核心思路是把同步的Either操作**提升（lift）**到TaskEither的上下文里，再用范畴内的组合子串联。这是函数式编程处理跨上下文计算的标准方式，也是fp-ts的惯用写法。

最优实现

先导入所需模块：

import { pipe, flow } from 'fp-ts/function';
import * as TE from 'fp-ts/TaskEither';

然后编写组合函数：

const fetchAndDecode = (id: string): TE.TaskEither<Error, MyDocumentT> =>
  pipe(
    fetchBlob(id),
    // 用flow组合decode和TE.fromEither，直接传给chain
    TE.chain(flow(decode, TE.fromEither))
  );

写法解释

TE.chain：TaskEither的核心组合子，用于串联依赖前一步结果的异步计算。这里传给它的函数，接收前一步的Body，先执行同步的decode得到Either<Error, MyDocumentT>，再通过TE.fromEither把这个同步的Either提升为异步的TaskEither。
flow：fp-ts的函数组合工具，把decode和TE.fromEither两个纯函数组合成一个Body => TE.TaskEither<Error, MyDocumentT>的函数，避免嵌套写法，让代码更简洁流畅。

等价的展开写法

如果觉得flow不够直观，也可以写成展开形式，逻辑完全一致：

const fetchAndDecode = (id: string): TE.TaskEither<Error, MyDocumentT> =>
  pipe(
    fetchBlob(id),
    TE.chain((body) => {
      const decoded = decode(body);
      return TE.fromEither(decoded);
    })
  );