使用 Sancuary 执行 Fluture 任务

Question

我有一个这样的管子

const asyncFn = (x) => {
    return Future.tryP(() => Promise.resolve(x + ' str2'))
};

const pipeResult = S.pipe([
    x => S.Right(x + " str1"), // some validation function
    S.map(asyncFn),
])("X");

pipeResult.fork(console.error, console.log);

我想在asyncFn. 问题是当我有Right输入时，我可以再分叉它。

当我登录时，pipeResult我看到：

Right (tryP(() => Promise.resolve(x + ' str2')))

我怎样才能做到这一点？

Answer 1

Either a b并且Future a b都能够表达失败/成功。在处理异步计算时，通常使用Future a b而不是Future a (Either b c). 更简单、更扁平的类型需要更少的映射：S.map (f)而不是S.map (S.map (f)). 另一个优点是，误差值始终在同一个地方，而与Future a (Either b c)这两个a和b代表失败的计算。

但是，我们可能已经有一个返回两者之一的验证函数。例如：

//    validateEmail :: String -> Either String String
const validateEmail = s =>
  s.includes ('@') ? S.Right (S.trim (s)) : S.Left ('Invalid email address');

如果我们有一个futtype值，Future String String我们如何验证电子邮件地址fut可能包含的内容？首先要尝试的是S.map：

S.map (validateEmail) (fut) :: Future String (Either String String)

避免这种嵌套会很好。为此，我们首先需要定义一个函数 from Either a bto Future a b：

//    eitherToFuture :: Either a b -> Future a b
const eitherToFuture = S.either (Future.reject) (Future.resolve);

我们现在可以将返回任一种的函数转换为返回未来的函数：

S.compose (eitherToFuture) (validateEmail) :: String -> Future String String

让我们重新审视我们的使用S.map：

S.map (S.compose (eitherToFuture) (validateEmail)) (fut) :: Future String (Future String String)

我们仍然有嵌套，但现在内部和外部类型都是Future String _. 这意味着我们可以更换S.map与S.chain避免引入嵌套：

S.chain (S.compose (eitherToFuture) (validateEmail)) (fut) :: Future String String