employer
/
liza
1
0
Fork 0
Code Releases Activity

DataValidator: properly chain queue

master
Mike Gerwitz 2017-02-21 16:24:23 -05:00
parent 6fb077d29c 2ac393070a
commit 071688159a
2 changed files with 23 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/validate/DataValidator.js
View File

@ -227,8 +227,10 @@ module.exports = Class( 'DataValidator',
{
if ( this._pending )
{
this._pending.then( callback );
return this._pending;
// we become the end of the chain
return this._pending = this._pending.then( () =>
this._onceReady( callback )
);
}
return this._pending = callback()

36
test/validate/DataValidatorTest.js
View File

@ -325,32 +325,34 @@ describe( 'DataValidator', () =>
} );
const { bstore } = getStore();
const faila = {};
const failb = {};
// linked list (to previous)
const fails = [ {}, {}, {} ];
fails.forEach( ( fail, i ) => fail.prev = fails[ i - 1 ] );
let running_first = true;
const failcalls = [];
vmonitor.update = ( _, fail ) =>
{
if ( fail === failb )
{
if ( running_first === true )
{
return Promise.reject( Error(
"Request not queued"
) );
}
}
failcalls.push( fail );
return Promise.resolve( true );
};
return Promise.all( [
sut.updateFailures( {}, faila )
.then( () => running_first = false ),
sut.updateFailures( {}, fails[ 0 ] )
.then( () => expect( failcalls[ 0 ] ).to.equal( fails[ 0 ] ) ),
sut.updateFailures( {}, failb ),
] );
sut.updateFailures( {}, fails[ 1 ] )
.then( () => expect( failcalls[ 1 ] ).to.equal( fails[ 1 ] ) ),
sut.updateFailures( {}, fails[ 2 ] )
.then( () => expect( failcalls[ 2 ] ).to.equal( fails[ 2 ] ) ),
] )
.then( () => {
// sanity check to make sure the above stuff was
// actually called
expect( failcalls.length )
.to.equal( fails.length )
} );
} );
} );