366 lines
9.0 KiB
Markdown
366 lines
9.0 KiB
Markdown
|
<!--
|
||
|
|
||
|
@license Apache-2.0
|
||
|
|
||
|
Copyright (c) 2018 The Stdlib Authors.
|
||
|
|
||
|
Licensed under the Apache License, Version 2.0 (the "License");
|
||
|
you may not use this file except in compliance with the License.
|
||
|
You may obtain a copy of the License at
|
||
|
|
||
|
http://www.apache.org/licenses/LICENSE-2.0
|
||
|
|
||
|
Unless required by applicable law or agreed to in writing, software
|
||
|
distributed under the License is distributed on an "AS IS" BASIS,
|
||
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||
|
See the License for the specific language governing permissions and
|
||
|
limitations under the License.
|
||
|
|
||
|
-->
|
||
|
|
||
|
# mapValuesAsync
|
||
|
|
||
|
> Map values from one object to a new object having the same keys.
|
||
|
|
||
|
<!-- Section to include introductory text. Make sure to keep an empty line after the intro `section` element and another before the `/section` close. -->
|
||
|
|
||
|
<section class="intro">
|
||
|
|
||
|
</section>
|
||
|
|
||
|
<!-- /.intro -->
|
||
|
|
||
|
<!-- Package usage documentation. -->
|
||
|
|
||
|
<section class="usage">
|
||
|
|
||
|
## Usage
|
||
|
|
||
|
```javascript
|
||
|
var mapValuesAsync = require( '@stdlib/utils/async/map-values' );
|
||
|
```
|
||
|
|
||
|
#### mapValuesAsync( obj, \[options,] transform, done )
|
||
|
|
||
|
Map values from one `object` to a new `object` having the same keys.
|
||
|
|
||
|
```javascript
|
||
|
function transform( value, next ) {
|
||
|
setTimeout( onTimeout, value );
|
||
|
function onTimeout() {
|
||
|
next( null, value*2 );
|
||
|
}
|
||
|
}
|
||
|
|
||
|
function done( error, out ) {
|
||
|
if ( error ) {
|
||
|
throw error;
|
||
|
}
|
||
|
console.log( out );
|
||
|
// => { 'a': 2, 'b': 4 }
|
||
|
}
|
||
|
|
||
|
var obj = {
|
||
|
'a': 1,
|
||
|
'b': 2
|
||
|
};
|
||
|
|
||
|
mapValuesAsync( obj, transform, done );
|
||
|
```
|
||
|
|
||
|
The `next` callback accepts two arguments: `error` and `value`. The second argument to the `next` callback is the transformed property value. If a `transform` function calls the `next` callback with a truthy error argument, the function stops processing any additional own properties and calls the `done` callback for error processing.
|
||
|
|
||
|
```javascript
|
||
|
function transform( value, key, next ) {
|
||
|
setTimeout( onTimeout, value );
|
||
|
function onTimeout() {
|
||
|
if ( key === 'a' ) {
|
||
|
return next( new Error( 'beep' ) );
|
||
|
}
|
||
|
next( null, value );
|
||
|
}
|
||
|
}
|
||
|
|
||
|
function done( error ) {
|
||
|
if ( error ) {
|
||
|
console.error( error.message );
|
||
|
// => 'beep'
|
||
|
}
|
||
|
}
|
||
|
|
||
|
var obj = {
|
||
|
'a': 1,
|
||
|
'b': 2
|
||
|
};
|
||
|
|
||
|
mapValuesAsync( obj, transform, done );
|
||
|
```
|
||
|
|
||
|
The function accepts the following `options`:
|
||
|
|
||
|
- `limit`: the maximum number of pending invocations at any one time. Default: `infinity`.
|
||
|
- `series`: `boolean` indicating whether to sequentially invoke the `transform` function for each own property. If `true`, the function sets `options.limit=1`. Default: `false`.
|
||
|
- `thisArg`: the execution context for `fcn`.
|
||
|
|
||
|
By default, all properties are processed concurrently, which means that the function does **not** guarantee completion order. To process each property sequentially, set the `series` option to `true`.
|
||
|
|
||
|
```javascript
|
||
|
function transform( value, next ) {
|
||
|
setTimeout( onTimeout, value );
|
||
|
function onTimeout() {
|
||
|
next( null, 'beep:'+value );
|
||
|
}
|
||
|
}
|
||
|
|
||
|
function done( error, out ) {
|
||
|
if ( error ) {
|
||
|
throw error;
|
||
|
}
|
||
|
console.log( out );
|
||
|
// => { 'a': 'beep:1', 'b': 'beep:2' }
|
||
|
}
|
||
|
|
||
|
var obj = {
|
||
|
'a': 1,
|
||
|
'b': 2
|
||
|
};
|
||
|
|
||
|
var opts = {
|
||
|
'series': true
|
||
|
};
|
||
|
|
||
|
mapValuesAsync( obj, opts, transform, done );
|
||
|
```
|
||
|
|
||
|
To limit the maximum number of pending function invocations, set the `limit` option.
|
||
|
|
||
|
```javascript
|
||
|
function transform( value, next ) {
|
||
|
setTimeout( onTimeout, value );
|
||
|
function onTimeout() {
|
||
|
next( null, 'beep:'+value );
|
||
|
}
|
||
|
}
|
||
|
|
||
|
function done( error, out ) {
|
||
|
if ( error ) {
|
||
|
throw error;
|
||
|
}
|
||
|
console.log( out );
|
||
|
// => { 'a': 'beep:1', 'b': 'beep:2', 'c': 'beep:3' }
|
||
|
}
|
||
|
|
||
|
var obj = {
|
||
|
'a': 1,
|
||
|
'b': 2,
|
||
|
'c': 3
|
||
|
};
|
||
|
|
||
|
var opts = {
|
||
|
'limit': 2
|
||
|
};
|
||
|
|
||
|
mapValuesAsync( obj, opts, transform, done );
|
||
|
```
|
||
|
|
||
|
To set the execution context of the `transform` function, set the `thisArg` option.
|
||
|
|
||
|
```javascript
|
||
|
function transform( value, next ) {
|
||
|
this.count += 1;
|
||
|
setTimeout( onTimeout, value );
|
||
|
function onTimeout() {
|
||
|
next( null, 'beep:'+value );
|
||
|
}
|
||
|
}
|
||
|
|
||
|
var obj = {
|
||
|
'a': 1,
|
||
|
'b': 2,
|
||
|
'c': 3
|
||
|
};
|
||
|
|
||
|
var context = {
|
||
|
'count': 0
|
||
|
};
|
||
|
|
||
|
var opts = {
|
||
|
'thisArg': context
|
||
|
};
|
||
|
|
||
|
mapValuesAsync( obj, opts, transform, done );
|
||
|
|
||
|
function done( error, out ) {
|
||
|
if ( error ) {
|
||
|
throw error;
|
||
|
}
|
||
|
console.log( out );
|
||
|
// => { 'a': 'beep:1', 'b': 'beep:2', 'c': 'beep:3' }
|
||
|
|
||
|
console.log( context.count );
|
||
|
// => 3
|
||
|
}
|
||
|
```
|
||
|
|
||
|
When invoked, the `transform` function is provided a maximum of four arguments:
|
||
|
|
||
|
- `value`: object value corresponding to `key`.
|
||
|
- `key`: object key.
|
||
|
- `obj`: source object.
|
||
|
- `next`: a callback which should be called once the `transform` function has finished processing a property `value`.
|
||
|
|
||
|
The actual number of provided arguments depends on function `length`. If the `transform` function accepts two arguments, the `transform` function is provided `value` and `next`. If the `transform` function accepts three arguments, the `transform` function is provided `value`, `key`, and `next`. For every other `transform` function signature, the `transform` function is provided all four arguments.
|
||
|
|
||
|
```javascript
|
||
|
function transform( value, key, obj, next ) {
|
||
|
console.log( 'obj: %s. %s: %d', JSON.stringify( obj ), key, value );
|
||
|
setTimeout( onTimeout, value );
|
||
|
function onTimeout() {
|
||
|
next( null, key+':'+value );
|
||
|
}
|
||
|
}
|
||
|
|
||
|
function done( error, out ) {
|
||
|
if ( error ) {
|
||
|
throw error;
|
||
|
}
|
||
|
console.log( out );
|
||
|
}
|
||
|
|
||
|
var obj = {
|
||
|
'a': 1,
|
||
|
'b': 2
|
||
|
};
|
||
|
|
||
|
mapValuesAsync( obj, transform, done );
|
||
|
/* => e.g.,
|
||
|
obj: {"a": 1, "b": 2}. a: 1
|
||
|
obj: {"a": 1, "b": 2}. b: 2
|
||
|
{ 'a': 'a:1', 'b': 'b:2' }
|
||
|
*/
|
||
|
```
|
||
|
|
||
|
#### mapValuesAsync.factory( \[options,] transform )
|
||
|
|
||
|
Returns a `function` which invokes a `transform` function once for each own property.
|
||
|
|
||
|
```javascript
|
||
|
function transform( value, next ) {
|
||
|
setTimeout( onTimeout, value );
|
||
|
function onTimeout() {
|
||
|
next( null, 'beep:'+value );
|
||
|
}
|
||
|
}
|
||
|
|
||
|
function done( error, out ) {
|
||
|
if ( error ) {
|
||
|
throw error;
|
||
|
}
|
||
|
console.log( out );
|
||
|
}
|
||
|
|
||
|
var f = mapValuesAsync.factory( transform );
|
||
|
|
||
|
var obj1 = {
|
||
|
'a': 1,
|
||
|
'b': 2
|
||
|
};
|
||
|
|
||
|
f( obj1, done );
|
||
|
// => { 'a': 'beep:1', 'b': 'beep:2' }
|
||
|
|
||
|
var obj2 = {
|
||
|
'c': 3,
|
||
|
'd': 4
|
||
|
};
|
||
|
|
||
|
f( obj2, done );
|
||
|
// => { 'c': 'beep:3', 'd': 'beep:4' }
|
||
|
```
|
||
|
|
||
|
The function accepts the same `options` as `mapValuesAsync()`.
|
||
|
|
||
|
</section>
|
||
|
|
||
|
<!-- /.usage -->
|
||
|
|
||
|
<!-- Package usage notes. Make sure to keep an empty line after the `section` element and another before the `/section` close. -->
|
||
|
|
||
|
<section class="notes">
|
||
|
|
||
|
## Notes
|
||
|
|
||
|
- If a provided function calls the `next` callback with a truthy `error` argument, the function suspends execution and immediately calls the `done` callback for subsequent `error` handling.
|
||
|
- If provided an empty `object`, the function calls the `done` callback with an empty `object`.
|
||
|
- Key iteration order is **not** guaranteed, as `object` key enumeration is not specified according to the [ECMAScript specification][ecma-262-for-in]. In practice, however, most engines use insertion order to sort an `object`'s keys, thus allowing for iteration order.
|
||
|
- Key insertion order is **not** guaranteed.
|
||
|
- The function only maps values assigned to **own** properties. Hence, the function does **not** map values for inherited properties.
|
||
|
- The function **shallow** copies key values.
|
||
|
- **Neither** `mapValuesAsync` nor the function returned by the `factory` method **guarantee** asynchronous execution. To guarantee asynchrony, wrap the `done` callback in a function which either executes at the end of the current stack (e.g., `nextTick`) or during a subsequent turn of the event loop (e.g., `setImmediate`, `setTimeout`).
|
||
|
|
||
|
</section>
|
||
|
|
||
|
<!-- /.notes -->
|
||
|
|
||
|
<!-- Package usage examples. -->
|
||
|
|
||
|
<section class="examples">
|
||
|
|
||
|
## Examples
|
||
|
|
||
|
<!-- eslint no-undef: "error" -->
|
||
|
|
||
|
```javascript
|
||
|
var resolve = require( 'path' ).resolve;
|
||
|
var stats = require( 'fs' ).stat;
|
||
|
var mapValuesAsync = require( '@stdlib/utils/async/map-values' );
|
||
|
|
||
|
var files = {
|
||
|
'file1': resolve( __dirname, 'package.json' ),
|
||
|
'file2': resolve( __dirname, 'README.md' )
|
||
|
};
|
||
|
|
||
|
function done( error, out ) {
|
||
|
if ( error ) {
|
||
|
throw error;
|
||
|
}
|
||
|
console.log( out );
|
||
|
}
|
||
|
|
||
|
function getStats( file, next ) {
|
||
|
stats( file, onStats );
|
||
|
|
||
|
function onStats( error, data ) {
|
||
|
if ( error ) {
|
||
|
error = new Error( 'unable to retrieve stats: '+file );
|
||
|
return next( error );
|
||
|
}
|
||
|
next( null, data );
|
||
|
}
|
||
|
}
|
||
|
|
||
|
mapValuesAsync( files, getStats, done );
|
||
|
```
|
||
|
|
||
|
</section>
|
||
|
|
||
|
<!-- /.examples -->
|
||
|
|
||
|
<!-- Section to include cited references. If references are included, add a horizontal rule *before* the section. Make sure to keep an empty line after the `section` element and another before the `/section` close. -->
|
||
|
|
||
|
<section class="references">
|
||
|
|
||
|
</section>
|
||
|
|
||
|
<!-- /.references -->
|
||
|
|
||
|
<!-- Section for all links. Make sure to keep an empty line after the `section` element and another before the `/section` close. -->
|
||
|
|
||
|
<section class="links">
|
||
|
|
||
|
[ecma-262-for-in]: http://www.ecma-international.org/ecma-262/5.1/#sec-12.6.4
|
||
|
|
||
|
</section>
|
||
|
|
||
|
<!-- /.links -->
|