Fix tests to pass with recent cleanup Begin/End for IO in PipeStream

The reason for this change is that previous cancellation implementation of
async IO was based on throwing OCE
(directly or via CancellationToken.ThrowIfCancellationRequested).
Since switching to TaskCompletionSource we use its SetCanceled method which
propagate on task TaskCanceledException instead of OCE.

Author: Maxwe11

src/System.IO.Pipes/tests/NamedPipeTests/NamedPipeTest.Simple.cs

@@ -498,15 +498,15 @@ public async Task Server_ReadWriteCancelledToken_Throws_OperationCanceledExcepti
                     var ctx1 = new CancellationTokenSource();
                     Task serverReadToken = server.ReadAsync(buffer, 0, buffer.Length, ctx1.Token);
                     ctx1.Cancel();
-                    await Assert.ThrowsAsync<OperationCanceledException>(() => serverReadToken);
+                    await Assert.ThrowsAnyAsync<OperationCanceledException>(() => serverReadToken);
                     Assert.True(server.ReadAsync(buffer, 0, buffer.Length, ctx1.Token).IsCanceled);
                 }
                 if (server.CanWrite)
                 {
                     var ctx1 = new CancellationTokenSource();
                     Task serverWriteToken = server.WriteAsync(buffer, 0, buffer.Length, ctx1.Token);
                     ctx1.Cancel();
-                    await Assert.ThrowsAsync<OperationCanceledException>(() => serverWriteToken);
+                    await Assert.ThrowsAnyAsync<OperationCanceledException>(() => serverWriteToken);
                     Assert.True(server.WriteAsync(buffer, 0, buffer.Length, ctx1.Token).IsCanceled);
                 }
             }
@@ -587,15 +587,15 @@ public async Task Client_ReadWriteCancelledToken_Throws_OperationCanceledExcepti
                     var ctx1 = new CancellationTokenSource();
                     Task serverReadToken = client.ReadAsync(buffer, 0, buffer.Length, ctx1.Token);
                     ctx1.Cancel();
-                    await Assert.ThrowsAsync<OperationCanceledException>(() => serverReadToken);
+                    await Assert.ThrowsAnyAsync<OperationCanceledException>(() => serverReadToken);
                     Assert.True(client.ReadAsync(buffer, 0, buffer.Length, ctx1.Token).IsCanceled);
                 }
                 if (client.CanWrite)
                 {
                     var ctx1 = new CancellationTokenSource();
                     Task serverWriteToken = client.WriteAsync(buffer, 0, buffer.Length, ctx1.Token);
                     ctx1.Cancel();
-                    await Assert.ThrowsAsync<OperationCanceledException>(() => serverWriteToken);
+                    await Assert.ThrowsAnyAsync<OperationCanceledException>(() => serverWriteToken);
                     Assert.True(client.WriteAsync(buffer, 0, buffer.Length, ctx1.Token).IsCanceled);
                 }
             }