forked from a-synchronous/rubico
-
Notifications
You must be signed in to change notification settings - Fork 0
/
assign.js
46 lines (44 loc) · 1.32 KB
/
assign.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
const isPromise = require('./_internal/isPromise')
const objectAssign = require('./_internal/objectAssign')
const __ = require('./_internal/placeholder')
const curry2 = require('./_internal/curry2')
const funcObjectAll = require('./_internal/funcObjectAll')
/**
* @name assign
*
* @synopsis
* ```coffeescript [specscript]
* var source Object,
* funcsObject Object<source=>Promise|any>
*
* assign(funcsObject)(source) -> resultsMergedWithSource Promise|Object
* ```
*
* @description
* Compose an object from a source object merged with the evaluations of a specifying object of functions. Functions of the specifying object may return Promises.
*
* ```javascript [playground]
* console.log(
* assign({
* squared: ({ number }) => number ** 2,
* cubed: ({ number }) => number ** 3,
* })({ number: 3 }),
* ) // { number: 3, squared: 9, cubed: 27 }
*
* assign({
* asyncNumber: async ({ number }) => number,
* })({ number: 3 }).then(console.log) // { number: 3, asyncNumber: 3 }
* ```
*
* @execution concurrent
*/
const assign = function (funcs) {
const allFuncs = funcObjectAll(funcs)
return function assignment(value) {
const result = allFuncs(value)
return isPromise(result)
? result.then(curry2(objectAssign, value, __))
: ({ ...value, ...result })
}
}
module.exports = assign