@@ -691,47 +691,4 @@ await db.Execute(
691691 await semAlwaysRunning . WaitAsync ( ) ;
692692 Assert . Equal ( 5 , callCount ) ;
693693 }
694-
695- [ Fact ( Timeout = 2000 ) ]
696- public async void WatchMultipleCancelledTest ( )
697- {
698- int callCount = 0 ;
699-
700- var watchHandlerFactory = ( SemaphoreSlim sem ) => new WatchHandler < IdResult >
701- {
702- OnResult = ( result ) =>
703- {
704- Interlocked . Increment ( ref callCount ) ;
705- sem . Release ( ) ;
706- } ,
707- OnError = ( ex ) => Assert . Fail ( ex . ToString ( ) ) ,
708- } ;
709-
710- var sem1 = new SemaphoreSlim ( 0 ) ;
711- var sem2 = new SemaphoreSlim ( 0 ) ;
712- using var query1 = await db . Watch ( "select id from assets" , null , watchHandlerFactory ( sem1 ) ) ;
713- using var query2 = await db . Watch ( "select id from assets" , null , watchHandlerFactory ( sem2 ) ) ;
714-
715- await Task . WhenAll ( sem1 . WaitAsync ( ) , sem2 . WaitAsync ( ) ) ;
716- Assert . Equal ( 2 , callCount ) ;
717-
718- await db . Execute (
719- "insert into assets(id, description, make) values (?, ?, ?)" ,
720- [ Guid . NewGuid ( ) . ToString ( ) , "some desc" , "some make" ]
721- ) ;
722- await Task . WhenAll ( sem1 . WaitAsync ( ) , sem2 . WaitAsync ( ) ) ;
723- Assert . Equal ( 4 , callCount ) ;
724-
725- db . UnsubscribeAllQueries ( ) ;
726-
727- await db . Execute (
728- "insert into assets(id, description, make) values (?, ?, ?)" ,
729- [ Guid . NewGuid ( ) . ToString ( ) , "some desc" , "some make" ]
730- ) ;
731- // Ensure no result received from either query
732- bool receivedResult = await sem1 . WaitAsync ( 100 ) || await sem2 . WaitAsync ( 100 ) ;
733- Assert . False ( receivedResult , "Received update after disposal" ) ;
734-
735- Assert . Equal ( 4 , callCount ) ;
736- }
737694}
0 commit comments