fp-ts 在管道中间使用异步函数

Question

我有 3 个函数，f1、f2、f3。

f1 和 f3 是同步函数，return Option<string> 但 f2 是异步函数 return Promise<Option<string>>。

如何在单个管道中使用这三个功能？

这是我的代码：

import {some, chain} from 'fp-ts/lib/Option';
import {pipe} from 'fp-ts/lib/pipeable';

const f1 = (input: string) => {
    return some(input + " f1")
};
const f2 = async (input: string) => {
    return some(input + " f2")
};
const f3 = (input: string) => {
    return some(input + " f3");
};

const result = pipe(
    "X",
    f1,
    chain(f2),
    chain(f3),
);

console.log("result", result);

Answer 1

我找到了使用 TaskOption

的解决方案

这是我的代码：

import * as O from 'fp-ts/lib/Option';
import * as TO from 'fp-ts-contrib/lib/TaskOption';
import {pipe} from 'fp-ts/lib/pipeable';
import {flow} from 'fp-ts/lib/function';

const f1 = (input: string): O.Option<string> => {
    return O.some(input + " f1")
};
const f2 = (input: string): TO.TaskOption<string> => async () => {
    return O.some(input + " f2")
};
const f3 = (input: string): O.Option<string> => {
    return O.some(input + " f3");
};

pipe(
    "X",
    flow(f1, TO.fromOption),
    TO.chain(f2),
    TO.chain(flow(f3,TO.fromOption)),
)().then(console.log);

我们使用 TO.fromOption.

将所有 Option 转换为 TaskOption

fp-ts 在管道中间使用异步函数

fp-ts Using async function in middle of pipe

typescript

asynchronous

functional-programming

pipe

fp-ts