TimeoutBlockingWaitStrategyTest.cs

using System;
using Moq;
using NUnit.Framework;

namespace Disruptor.Tests
{
    [TestFixture]
    public class TimeoutBlockingWaitStrategyTest
    {
        [Test]
        public void ShouldTimeoutWaitFor()
        {
            var sequenceBarrier = new Mock<ISequenceBarrier>();

            var theTimeout = TimeSpan.FromMilliseconds(500);
            TimeoutBlockingWaitStrategy waitStrategy = new TimeoutBlockingWaitStrategy(theTimeout);
            Sequence cursor = new Sequence(5);
            Sequence dependent = cursor;

            var t0 = DateTime.UtcNow;

            try
            {
                waitStrategy.WaitFor(6, cursor, dependent, sequenceBarrier.Object);
                throw new ApplicationException("TimeoutException should have been thrown");
            }
            catch (TimeoutException e)
            {
            }

            var t1 = DateTime.UtcNow;

            var timeWaiting = t1 - t0;

            sequenceBarrier.Verify(x => x.CheckAlert());
            Assert.That(timeWaiting, Is.GreaterThanOrEqualTo(theTimeout));
        }
    }
}