src/Carnac.Tests/KeysControllerFacts.cs

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

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

using System;
using System.Collections.ObjectModel;
using System.Linq;
using System.Windows.Forms;
using Carnac.Logic;
using Carnac.Logic.KeyMonitor;
using Carnac.Logic.Models;
using Microsoft.Reactive.Testing;
using NSubstitute;
using Shouldly;
using Xunit;
using Message = Carnac.Logic.Models.Message;

namespace Carnac.Tests
{
    public class KeysControllerFacts
    {
        const int MessageAOnNextTick = 100;

        readonly ObservableCollection<Message> messages = new ObservableCollection<Message>();
        readonly TestScheduler testScheduler;
        readonly Message messageA = new Message(A);

        public KeysControllerFacts()
        {
            testScheduler = new TestScheduler();
        }

        KeysController CreateKeysController(IObservable<Message> messageStream)
        {
            var messageProvider = Substitute.For<IMessageProvider>();
            messageProvider.GetMessageStream().Returns(_ => messageStream);
            var concurrencyService = Substitute.For<IConcurrencyService>();
            concurrencyService.MainThreadScheduler.Returns(testScheduler);
            concurrencyService.Default.Returns(testScheduler);
            return new KeysController(messages, messageProvider, concurrencyService);
        }

        [Fact]
        public void MessagesAreAddedIntoKeysColletion()
        {
            var sut = CreateKeysController(SingleMessageAt100Ticks());
            sut.Start();
            testScheduler.AdvanceTo(MessageAOnNextTick + 1);  //+1 for the cost of the ObserveOn scheduling

            messages.ShouldContain(messageA);
            messageA.IsDeleting.ShouldBe(false);
        }

        [Fact]
        public void MessagesAreFlaggedAsDeletingAfter5Seconds()
        {
            var sut = CreateKeysController(SingleMessageAt100Ticks());
            sut.Start();
            testScheduler.AdvanceBy(MessageAOnNextTick + 1);
            testScheduler.AdvanceBy(5.Seconds());

            Assert.Single(messages);
            messages.Single().ShouldBe(messageA.FadeOut());
        }