src/Testing/test/TaskExtensionsTest.cs - main - githubmirror/aspnetcore

src/Testing/test/TaskExtensionsTest.cs
89 строк3 KB
William Godbe
Rename Microsoft.Aspnetcore.Testing to Microsoft.AspNetCore.InternalTesting (#51713)
02 ноя 2023, 03:15
02 ноя 2023, 03:15fc8deca
// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.

using System;
using System.Threading;
using System.Threading.Tasks;
using Xunit;

namespace Microsoft.AspNetCore.InternalTesting;

public class TaskExtensionsTest
{
    [Fact]
    public async Task TimeoutAfterTest()
    {
        var cts = new CancellationTokenSource();
        await Assert.ThrowsAsync<TimeoutException>(async () => await Task.Delay(30000, cts.Token).TimeoutAfter(TimeSpan.FromMilliseconds(50)));
        cts.Cancel();
    }

    [Fact]
    public async Task TimeoutAfter_DoesNotThrowWhenCompleted()
    {
        await Task.FromResult(true).TimeoutAfter(TimeSpan.FromMilliseconds(30000));
    }

    [Fact]
    public async Task TimeoutAfter_DoesNotThrow_WithinTimeoutPeriod()
    {
        await Task.Delay(10).TimeoutAfter(TimeSpan.FromMilliseconds(30000));
    }

    [Fact]
    public async Task DefaultTimeout_WithTimespan()
    {
        var cts = new CancellationTokenSource();
        await Assert.ThrowsAsync<TimeoutException>(async () => await Task.Delay(30000, cts.Token).DefaultTimeout(TimeSpan.FromMilliseconds(50)));
        cts.Cancel();
    }

    [Fact]
    public async Task DefaultTimeout_WithMilliseconds()
    {
        var cts = new CancellationTokenSource();
        await Assert.ThrowsAsync<TimeoutException>(async () => await Task.Delay(30000, cts.Token).DefaultTimeout(50));
        cts.Cancel();
    }

    [Fact]
    public async Task DefaultTimeout_Message_ContainsLineNumber()
    {
        var cts = new CancellationTokenSource();
        await Assert.ThrowsAsync<TimeoutException>(async () => await Task.Delay(30000, cts.Token).DefaultTimeout(50));
        cts.Cancel();
    }

    [Fact]
    public async Task DefaultTimeout_DoesNotThrowWhenCompleted()
    {
        await Task.FromResult(true).DefaultTimeout();
    }

    [Theory]
    [InlineData("This is my custom timeout exception message.")]
    public async Task Task_TimeoutAfter_DoesNotRethrow_NonWaitAsyncTimeouts(string message)
    {
        async Task ExpectedTimeout()
        {
            await Task.Delay(10);
            throw new TimeoutException(message);
        }
        var exception = await Assert.ThrowsAsync<TimeoutException>(() => ExpectedTimeout().TimeoutAfter(TimeSpan.FromMilliseconds(30000)));
        Assert.Equal(message, exception.Message);
    }

    [Theory]
    [InlineData("This is my custom timeout exception message.")]
    public async Task TaskT_TimeoutAfter_DoesNotRethrow_NonWaitAsyncTimeouts(string message)
    {
        async Task<bool> ExpectedTimeout()
        {
            await Task.Delay(10);
            throw new TimeoutException(message);
        }
        var exception = await Assert.ThrowsAsync<TimeoutException>(() => ExpectedTimeout().TimeoutAfter(TimeSpan.FromMilliseconds(30000)));
        Assert.Equal(message, exception.Message);
    }

}