everyByRightAsync
Test whether all elements in a collection pass a test implemented by a predicate function, iterating from right to left.
Usage
var everyByRightAsync = require( '@stdlib/utils/async/every-by-right' );
everyByRightAsync( collection, [options,] predicate, done )
Tests whether all elements in a collection
pass a test implemented by a predicate
function, iterating from right to left.
function predicate( value, next ) {
setTimeout( onTimeout, value );
function onTimeout() {
console.log( value );
/* =>
1000
2500
3000
*/
next( null, true );
}
}
function done( error, bool ) {
if ( error ) {
throw error;
}
console.log( bool );
// => true
}
var arr = [ 1000, 2500, 3000 ];
everyByRightAsync( arr, predicate, done );
If a predicate
function calls the next
callback with a non-truthy test argument, the function stops processing any additional collection
elements and returns false
for the test result.
function predicate( value, index, next ) {
setTimeout( onTimeout, value );
function onTimeout() {
if ( index === 1 ) {
return next( null, false );
}
next( null, true );
}
}
function done( error, bool ) {
if ( error ) {
throw error;
}
console.log( bool );
// => false
}
var arr = [ 1000, 2500, 3000 ];
everyByRightAsync( arr, predicate, 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 thepredicate
function for eachcollection
element. Iftrue
, the function setsoptions.limit=1
. Default:false
.thisArg
: the execution context forpredicate
.
By default, all elements are processed concurrently, which means that the function does not guarantee completion order. To process each collection
element sequentially, set the series
option to true
.
function predicate( value, next ) {
setTimeout( onTimeout, value );
function onTimeout() {
console.log( value );
/* =>
3000
2500
1000
*/
next( null, true );
}
}
function done( error, bool ) {
if ( error ) {
throw error;
}
console.log( bool );
// => true
}
var arr = [ 1000, 2500, 3000 ];
var opts = {
'series': true
};
everyByRightAsync( arr, opts, predicate, done );
To limit the maximum number of pending function invocations, set the limit
option.
function predicate( value, next ) {
setTimeout( onTimeout, value );
function onTimeout() {
console.log( value );
/* =>
2500
3000
1000
*/
next( null, true );
}
}
function done( error, bool ) {
if ( error ) {
throw error;
}
console.log( bool );
// => true
}
var arr = [ 1000, 2500, 3000 ];
var opts = {
'limit': 2
};
everyByRightAsync( arr, opts, predicate, done );
To set the execution context of the predicate
function, set the thisArg
option.
function predicate( value, next ) {
this.count += 1;
setTimeout( onTimeout, value );
function onTimeout() {
next( null, true );
}
}
var arr = [ 1000, 2500, 3000 ];
var context = {
'count': 0
};
var opts = {
'thisArg': context
};
everyByRightAsync( arr, opts, predicate, done );
function done( error, bool ) {
if ( error ) {
throw error;
}
console.log( bool );
// => true
console.log( context.count );
// => 3
}
When invoked, the predicate
function is provided a maximum of four arguments:
value
: collection value.index
: collection index.collection
: the inputcollection
.next
: a callback which should be called once thepredicate
function has finished processing a collectionvalue
.
The actual number of provided arguments depends on function length
. If the predicate
function accepts two arguments, the predicate
function is provided value
and next
. If the predicate
function accepts three arguments, the predicate
function is provided value
, index
, and next
. For every other predicate
function signature, the predicate
function is provided all four arguments.
function predicate( value, i, collection, next ) {
console.log( 'collection: %s. %d: %d', collection.join( ',' ), i, value );
/* =>
collection: 3000,2500,1000. 2: 3000
collection: 3000,2500,1000. 1: 2500
collection: 3000,2500,1000. 0: 1000
*/
setTimeout( onTimeout, value );
function onTimeout() {
console.log( value );
/* =>
1000
2500
3000
*/
next( null, true );
}
}
function done( error, bool ) {
if ( error ) {
throw error;
}
console.log( bool );
// => true
}
var arr = [ 1000, 2500, 3000 ];
everyByRightAsync( arr, predicate, done );
everyByRightAsync.factory( [options,] predicate )
Returns a function
which invokes a predicate
function once for each element in a collection
, iterating from right to left.
function predicate( value, next ) {
setTimeout( onTimeout, value );
function onTimeout() {
console.log( value );
next( null, true );
}
}
function done( error, bool ) {
if ( error ) {
throw error;
}
console.log( bool );
}
var f = everyByRightAsync.factory( predicate );
var arr1 = [ 1000, 2500, 3000 ];
f( arr1, done );
/* e.g., =>
1000
2500
3000
true
*/
var arr2 = [ 100, 250, 300 ];
f( arr2, done );
/* e.g., =>
100
250
300
true
*/
The function accepts the same options
as everyByRightAsync()
.
Notes
- A
collection
may be either anArray
,Typed Array
, or an array-likeObject
(excludingstrings
andfunctions
). - If a provided function calls the
next
callback with a truthyerror
argument, the function suspends execution and immediately calls thedone
callback for subsequenterror
handling. - The function does not support dynamic
collection
resizing. - The function does not skip
undefined
elements. - If provided an empty
collection
, the function calls thedone
callback withtrue
as the test result. - Neither
everyByRightAsync
nor the function returned by thefactory
method guarantee asynchronous execution. To guarantee asynchrony, wrap thedone
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
).
Examples
var resolve = require( 'path' ).resolve;
var readFile = require( '@stdlib/fs/read-file' );
var everyByRightAsync = require( '@stdlib/utils/async/every-by-right' );
var files = [
resolve( __dirname, 'package.json' ),
resolve( __dirname, 'README.md' )
];
function done( error, bool ) {
if ( error ) {
throw error;
}
if ( bool ) {
console.log( 'Successfully read all files.' );
} else {
console.log( 'Was unable to read all files.' );
}
}
function predicate( file, next ) {
var opts = {
'encoding': 'utf8'
};
readFile( file, opts, onFile );
function onFile( error ) {
if ( error ) {
return next( null, false );
}
next( null, true );
}
}
everyByRightAsync( files, predicate, done );