如何使用任务单？(fp-ts)

Question

import * as T from 'fp-ts/lib/Task'
import { pipe, flow } from 'fp-ts/lib/function'

const getHello: T.Task<string> = () => new Promise((resolve) => {
  resolve('hello')
})

我理解Task的目的以及为什么它是重要的。问题是，我不知道如何正确地使用它，也不知道如何组合它，真的。

如果我给getHello()打电话，它会给我Promise<pending>

console.log(getHello()) // returns Promise<pending>

然而，如果我这样做：

const run = async () => {
  const hello = await getHello()
  console.log(hello) // prints 'hello'
}

它起作用了。

但这一点：

const waitAndGet = async () => {
  return await getHello()
}

console.log(waitAndGet()) // prints Promise<pending>

不会的。

此外，我怎样才能与它合拍呢？就像这样：

const getHelloAndAddWorld = flow(
  getHello(),
  addAtEnd('world')
)

Answer 1

首先，让我们了解一下Task到底是什么。

export interface Task<A> {
  (): Promise<A>
}

// note that this could also be written as
export type Task<A> = () => Promise<A>

Task只是一个返回Promise的函数，所以在您的示例中，调用getHello将返回一个Promise<string>。

console.log(getHello())和console.log(Promise.resolve('hello'))是一样的，所以这就是为什么它会记录像Promise {<fulfilled>: "hello"}、Promise<pending>之类的东西，或者其他东西而不是hello。

​

// Promise.resolve(foo) is the same as new Promise(resolve => resolve(foo))
const getHello = () => Promise.resolve('hello')
console.log(getHello())

​

有关承诺的更多信息，我建议阅读在MDN上使用承诺。

至于如何与其组合，由于Task是一个Monad，所以可以使用map、ap、chain、apSecond等。

例如，假设addAtEnd是这样定义的：

const addAtEnd = (b: string) => (a: string): string => a + b

您可以通过使用getHello()来使用Task.map。

import * as T from 'fp-ts/Task'
import { pipe } from 'fp-ts/function'

// type of map:
// export declare const map: <A, B>(f: (a: A) => B) => (fa: Task<A>) => Task<B>

// Task<string> which, when called, would resolve to 'hello world'
const getHelloAndAddWorld = pipe(
  getHello,
  T.map(addAtEnd(' world'))
)

// same as
const getHelloAndAddWorld = T.map(addAtEnd(' world'))(getHello)

或者，如果您想记录该值，可以使用chainIOK和Console.log。

import * as Console from 'fp-ts/Console'

// type of T.chainIOK:
// export declare function chainIOK<A, B>(f: (a: A) => IO<B>): (ma: Task<A>) => Task<B>

// type of Console.log:
// export declare function log(s: unknown): IO<void>

// Note that IO<A> is a function that (usually) does a side-effect and returns A
// (() => A)

// Task<void>
const logHelloAndWorld = pipe(
  getHelloAndAddWorld,
  T.chainIOK(Console.log)
)

// same as
const logHelloAndWorld = pipe(
  getHello,
  T.map(addAtEnd(' world')),
  T.chainIOK(Console.log)
)

要执行Task，只需调用它：

logHelloAndWorld() // logs 'hello world'

对于函子、应用程序和单子的简单介绍，“图中的函子、应用程序和单数”或慈祥林的JavaScript版本是一些很好的起点。