File tree Expand file tree Collapse file tree
Tests/PowerSync/PowerSync.Common.Tests Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -217,24 +217,25 @@ public async Task EventManager_ShouldNotReceiveEventsAfterDeregistering()
217217
218218 var cts = new CancellationTokenSource ( ) ;
219219 var listener = stream . ListenAsync ( cts . Token ) ;
220+ var tcs = new TaskCompletionSource < bool > ( ) ;
220221 var sem = new SemaphoreSlim ( 0 ) ;
221222 int eventCount = 0 ;
222223
223224 _ = Task . Run ( async ( ) =>
224225 {
225- sem . Release ( ) ;
226+ tcs . SetResult ( true ) ;
226227 await foreach ( var evt in listener )
227228 {
228229 eventCount ++ ;
229230 sem . Release ( ) ;
230231 }
231232 } , cts . Token ) ;
232- Assert . True ( await sem . WaitAsync ( 100 ) ) ;
233+ await tcs . Task ;
233234
234235 Assert . True ( manager . Deregister < string > ( ) ) ;
235236
236237 Assert . False ( manager . TryEmit ( "invalid" ) ) ;
237- Assert . False ( await sem . WaitAsync ( 100 ) ) ;
238+ Assert . False ( await sem . WaitAsync ( 500 ) ) ;
238239
239240 // Cleanup
240241 cts . Cancel ( ) ;
You can’t perform that action at this time.
0 commit comments