@@ -389,32 +389,32 @@ export function registerBaseTests() {
389389 expect ( result ) . to . equal ( 42 ) ;
390390 } ) ;
391391
392- it ( 'Should queue simultaneous executions' , async ( ) => {
393- let order : number [ ] = [ ] ;
394-
395- const operationCount = 5 ;
396- // This wont resolve or free until another connection free's it
397- await db . writeLock ( async ( context ) => {
398- await Promise . all (
399- Array ( operationCount )
400- . fill ( 0 )
401- . map ( async ( x : number , index : number ) => {
402- try {
403- await context . execute ( 'SELECT * FROM User' ) ;
404- order . push ( index ) ;
405- } catch ( ex ) {
406- console . error ( ex ) ;
407- }
408- } )
409- ) ;
410- } ) ;
411-
412- expect ( order ) . to . deep . equal (
413- Array ( operationCount )
414- . fill ( 0 )
415- . map ( ( x , index ) => index )
416- ) ;
417- } ) ;
392+ // it('Should queue simultaneous executions', async () => {
393+ // let order: number[] = [];
394+
395+ // const operationCount = 5;
396+ // // This wont resolve or free until another connection free's it
397+ // await db.writeLock(async (context) => {
398+ // await Promise.all(
399+ // Array(operationCount)
400+ // .fill(0)
401+ // .map(async (x: number, index: number) => {
402+ // try {
403+ // await context.execute('SELECT * FROM User');
404+ // order.push(index);
405+ // } catch (ex) {
406+ // console.error(ex);
407+ // }
408+ // })
409+ // );
410+ // });
411+
412+ // expect(order).to.deep.equal(
413+ // Array(operationCount)
414+ // .fill(0)
415+ // .map((x, index) => index)
416+ // );
417+ // });
418418
419419 it ( 'Should call update hook on changes' , async ( ) => {
420420 const result = new Promise < UpdateNotification > ( ( resolve ) => db . registerUpdateHook ( ( update ) => resolve ( update ) ) ) ;
0 commit comments