PureEvalIO(Monad)
IO 是一个用来控制流程、隔离副作用的单子。
此处是一个 IO 单子使用的总例。
js
import { readFileSync } from 'fs';
const myReadFileSync = (path) => IO(() => fs.readFileSync(path, 'utf8'));
const print = (message) => IO(() => console.log(message));
const program = myReadFileSync('./example.txt').chain((content) => print(content));
program.run();import { readFileSync } from 'fs';
const myReadFileSync = (path) => IO(() => fs.readFileSync(path, 'utf8'));
const print = (message) => IO(() => console.log(message));
const program = myReadFileSync('./example.txt').chain((content) => print(content));
program.run();IO
IO 的构造函数，用来进行 IO 的常规构造，传入的值必须是一个函数。
- Type
- Example
js
IO(() => 1); //IO 1IO(() => 1); //IO 1IO.map()
对 IO 中的值进行映射。
- Type
- Example
js
IO(() => 1).map(add(1)); //IO 2IO(() => 1).map(add(1)); //IO 2IO.chain()
在当前 IO 任务后拼接新的 IO 任务。
- Type
- Example
js
const readFile = (filename) => IO(() => fs.readFileSync(filename, 'utf-8'));
const parseJSON = (str) => IO(() => JSON.parse(str));
const getProp = (prop) => (obj) => IO(() => obj[prop]);
const example = readFile('example.json')
.chain(parseJSON)
.chain(getProp('data'))
.map((data) => data.toUpperCase())
.run();
console.log(example);const readFile = (filename) => IO(() => fs.readFileSync(filename, 'utf-8'));
const parseJSON = (str) => IO(() => JSON.parse(str));
const getProp = (prop) => (obj) => IO(() => obj[prop]);
const example = readFile('example.json')
.chain(parseJSON)
.chain(getProp('data'))
.map((data) => data.toUpperCase())
.run();
console.log(example);IO.handle(Algebraic Effects)
handle 方法是一个代数效应(Algebraic Effects)的实现。
采用该方法可以挂载 perform 函数的内容到 IO 上，进而在 effect 中通过 perform 函数执行。
- Type
- Example
js
//calc 1*x + 2*y + 3*z
function foo(x, y, z) {
return IO((perform) => {
const a = 1 * perform('x');
const b = 2 * perform('y');
const c = 3 * perform('z');
return a + b + c;
})
.handle(match('x', x, 'y', y, 'z', z))
.run();
}
console.log(foo(1, 2, 3)); //14//calc 1*x + 2*y + 3*z
function foo(x, y, z) {
return IO((perform) => {
const a = 1 * perform('x');
const b = 2 * perform('y');
const c = 3 * perform('z');
return a + b + c;
})
.handle(match('x', x, 'y', y, 'z', z))
.run();
}
console.log(foo(1, 2, 3)); //14IO.run()
一个 IO 单子在没有执行 run 方法之前都是不会执行的。
run 方法用来执行一个 IO 单子。
WARNING
这个操作是 Unsafe 的。
- Type
- Example
js
const readFile = (filename) => IO(() => fs.readFileSync(filename, 'utf-8'));
const parseJSON = (str) => IO(() => JSON.parse(str));
const getProp = (prop) => (obj) => IO(() => obj[prop]);
const example = readFile('example.json')
.chain(parseJSON)
.chain(getProp('data'))
.map((data) => data.toUpperCase())
.run();
console.log(example);const readFile = (filename) => IO(() => fs.readFileSync(filename, 'utf-8'));
const parseJSON = (str) => IO(() => JSON.parse(str));
const getProp = (prop) => (obj) => IO(() => obj[prop]);
const example = readFile('example.json')
.chain(parseJSON)
.chain(getProp('data'))
.map((data) => data.toUpperCase())
.run();
console.log(example);