Removed synchronous wait to avoid xunit deadlocks

Author: sakno

src/DotNext.Tests/IO/AsyncBinaryReaderWriterTests.cs

@@ -102,12 +102,7 @@ private sealed class PipeSource : IAsyncBinaryReaderWriterSource, IFlushable
         public Task FlushAsync(CancellationToken token)
             => pipe.Writer.FlushAsync(token).AsTask();
 
-        void IFlushable.Flush()
-        {
-            using var timeoutSource = new CancellationTokenSource(DefaultTimeout);
-            using var task = FlushAsync(timeoutSource.Token);
-            task.Wait();
-        }
+        void IFlushable.Flush() => throw new NotSupportedException();
 
         public async ValueTask DisposeAsync()
         {
@@ -154,13 +149,7 @@ public FileSource(int bufferSize)
 
         public Task FlushAsync(CancellationToken token) => writer.WriteAsync(token).AsTask();
 
-        void IFlushable.Flush()
-        {
-            using var cts = new CancellationTokenSource();
-            using var task = FlushAsync(cts.Token);
-            cts.CancelAfter(DefaultTimeout);
-            task.Wait();
-        }
+        void IFlushable.Flush() => throw new NotSupportedException();
 
         protected override void Dispose(bool disposing)
         {

src/DotNext.Tests/Threading/Tasks/SynchronizationTests.cs

@@ -184,34 +184,40 @@ public static async Task WhenAllWithResult5()
     public static void SynchronousWait()
     {
         var cts = new TaskCompletionSource();
-        var task = new ValueTask(cts.Task);
-        ThreadPool.UnsafeQueueUserWorkItem(static cts =>
+        var thread = new Thread(() =>
         {
-            Thread.Sleep(100);
-            cts.SetResult();
-        }, cts, preferLocal: false);
-        task.Wait();
+            var task = new ValueTask(cts.Task);
+            task.Wait();
+            
+            // ensure that the current thread in not interrupted
+            Thread.Sleep(0);
+        });
 
-        // ensure that the current thread in not interrupted
-        Thread.Sleep(0);
+        thread.Start();
+        Thread.Sleep(100);
+
+        cts.TrySetResult();
+        thread.Join();
     }
-    
+
     [Fact]
     public static void SynchronousWaitWithResult()
     {
-        var cts = new TaskCompletionSource<int>();
-        var task = new ValueTask<int>(cts.Task);
-
         const int expected = 42;
-        ThreadPool.UnsafeQueueUserWorkItem(static cts =>
+        var cts = new TaskCompletionSource<int>();
+        var thread = new Thread(() =>
         {
-            Thread.Sleep(100);
-            cts.SetResult(expected);
-        }, cts, preferLocal: false);
-        
-        Equal(expected, task.Wait());
-        
-        // ensure that the current thread in not interrupted
-        Thread.Sleep(0);
+            var task = new ValueTask<int>(cts.Task);
+            Equal(expected, task.Wait());
+
+            // ensure that the current thread in not interrupted
+            Thread.Sleep(0);
+        });
+
+        thread.Start();
+        Thread.Sleep(100);
+
+        cts.TrySetResult(42);
+        thread.Join();
     }
 }