tests/DotNetCommon.Test/Extensions/TaskExtensions/TaskGeneralTests.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

namespace DotNetCommon.Test.Extensions.TaskExtensions
{
    using System;
    using System.Collections.Concurrent;
    using System.Collections.Generic;
    using System.Threading.Tasks;
    using NUnit.Framework;
    using Shouldly;
    using DotNetCommon.Extensions;

    [TestFixture]
    internal sealed class TaskGeneralTests
    {
        [Test]
        public async Task When_iterating_over_tasks_finishing_in_order()
        {
            var tasks = new[]
            {
                DoSomethingAfter(500.Milliseconds()),
                DoSomethingAfter(1000.Milliseconds()),
                DoSomethingAfter(1500.Milliseconds())
            };

            var finishedTasksIds = new List<int>(3);
            Action<Task> work = t => finishedTasksIds.Add(t.Id);

            await tasks.ForEachInOrder(work);

            finishedTasksIds.ShouldNotBeEmpty();
            finishedTasksIds.Count.ShouldBe(3);

            finishedTasksIds[0].ShouldBe(tasks[0].Id);
            finishedTasksIds[1].ShouldBe(tasks[1].Id);
            finishedTasksIds[2].ShouldBe(tasks[2].Id);
        }

        [Test]
        public async Task When_iterating_over_tasks_finishing_out_of_order()
        {
            var tasks = new[]
            {
                DoSomethingAfter(1500.Milliseconds()),
                DoSomethingAfter(1000.Milliseconds()),
                DoSomethingAfter(500.Milliseconds())
            };

            var finishedTasksIds = new List<int>(3);
            Action<Task> work = t => finishedTasksIds.Add(t.Id);

            await tasks.ForEachInOrder(work);

            finishedTasksIds.ShouldNotBeEmpty();
            finishedTasksIds.Count.ShouldBe(3);

            finishedTasksIds[0].ShouldBe(tasks[0].Id);
            finishedTasksIds[1].ShouldBe(tasks[1].Id);
            finishedTasksIds[2].ShouldBe(tasks[2].Id);
        }

        [Test]