123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297 |
- // Licensed to the .NET Foundation under one or more agreements.
- // The .NET Foundation licenses this file to you under the MIT License.
- // See the LICENSE file in the project root for more information.
- #if HAS_WINFORMS
- using System;
- using System.Reactive.Concurrency;
- using System.Reactive.Disposables;
- using System.Diagnostics;
- using System.Threading;
- using System.Windows.Forms;
- using Microsoft.VisualStudio.TestTools.UnitTesting;
- using Microsoft.Reactive.Testing;
- using Assert = Xunit.Assert;
- namespace ReactiveTests.Tests
- {
- [TestClass]
- public class ControlSchedulerTest
- {
- [TestMethod]
- public void Ctor_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => new ControlScheduler(null));
- }
- [TestMethod]
- public void Control()
- {
- var lbl = new Label();
- Assert.Same(lbl, new ControlScheduler(lbl).Control);
- }
- [TestMethod]
- public void Now()
- {
- var res = new ControlScheduler(new Label()).Now - DateTime.Now;
- Assert.True(res.Seconds < 1);
- }
- [TestMethod]
- public void Schedule_ArgumentChecking()
- {
- var s = new ControlScheduler(new Label());
- ReactiveAssert.Throws<ArgumentNullException>(() => s.Schedule(42, default(Func<IScheduler, int, IDisposable>)));
- ReactiveAssert.Throws<ArgumentNullException>(() => s.Schedule(42, TimeSpan.FromSeconds(1), default(Func<IScheduler, int, IDisposable>)));
- ReactiveAssert.Throws<ArgumentNullException>(() => s.Schedule(42, DateTimeOffset.Now, default(Func<IScheduler, int, IDisposable>)));
- }
- [TestMethod]
- public void Schedule()
- {
- using (WinFormsTestUtils.RunTest(out var lbl))
- {
- var evt = new ManualResetEvent(false);
- var id = Thread.CurrentThread.ManagedThreadId;
- var sch = new ControlScheduler(lbl);
-
- sch.Schedule(() => { lbl.Text = "Okay"; Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId); });
- sch.Schedule(() => { Assert.Equal("Okay", lbl.Text); Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId); evt.Set(); });
- evt.WaitOne();
- }
- }
- [TestMethod]
- public void ScheduleError()
- {
- using (WinFormsTestUtils.RunTest(out var lbl))
- {
- var evt = new ManualResetEvent(false);
- var ex = new Exception();
- lbl.Invoke(new Action(() =>
- {
- Application.ThreadException += (o, e) =>
- {
- Assert.Same(ex, e.Exception);
- evt.Set();
- };
- }));
- var sch = new ControlScheduler(lbl);
- sch.Schedule(() => { throw ex; });
- evt.WaitOne();
- }
- }
- [TestMethod]
- public void ScheduleRelative()
- {
- ScheduleRelative_(TimeSpan.FromSeconds(0.1));
- }
- [TestMethod]
- public void ScheduleRelative_Zero()
- {
- ScheduleRelative_(TimeSpan.Zero);
- }
- private void ScheduleRelative_(TimeSpan delay)
- {
- using (WinFormsTestUtils.RunTest(out var lbl))
- {
- var evt = new ManualResetEvent(false);
- var id = Thread.CurrentThread.ManagedThreadId;
-
- var sch = new ControlScheduler(lbl);
- sch.Schedule(delay, () =>
- {
- lbl.Text = "Okay";
- Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
-
- sch.Schedule(() =>
- {
- Assert.Equal("Okay", lbl.Text);
- Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
- evt.Set();
- });
- });
- evt.WaitOne();
- }
- }
- [TestMethod]
- public void ScheduleRelative_Nested()
- {
- using (WinFormsTestUtils.RunTest(out var lbl))
- {
- var evt = new ManualResetEvent(false);
- var id = Thread.CurrentThread.ManagedThreadId;
- var sch = new ControlScheduler(lbl);
- sch.Schedule(TimeSpan.FromSeconds(0.1), () =>
- {
- sch.Schedule(TimeSpan.FromSeconds(0.1), () =>
- {
- lbl.Text = "Okay";
- Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
- sch.Schedule(() =>
- {
- Assert.Equal("Okay", lbl.Text);
- Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
- evt.Set();
- });
- });
- });
- evt.WaitOne();
- }
- }
- [TestMethod]
- public void ScheduleRelative_Cancel()
- {
- using (WinFormsTestUtils.RunTest(out var lbl))
- {
- var evt = new ManualResetEvent(false);
- var id = Thread.CurrentThread.ManagedThreadId;
- var sch = new ControlScheduler(lbl);
- sch.Schedule(TimeSpan.FromSeconds(0.1), () =>
- {
- lbl.Text = "Okay";
- Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
- var d = sch.Schedule(TimeSpan.FromSeconds(0.1), () =>
- {
- lbl.Text = "Oops!";
- });
- sch.Schedule(() =>
- {
- d.Dispose();
- });
- sch.Schedule(TimeSpan.FromSeconds(0.2), () =>
- {
- Assert.Equal("Okay", lbl.Text);
- Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
- evt.Set();
- });
- });
- evt.WaitOne();
- }
- }
- [TestMethod]
- public void SchedulePeriodic_ArgumentChecking()
- {
- var s = new ControlScheduler(new Label());
- ReactiveAssert.Throws<ArgumentNullException>(() => s.SchedulePeriodic(42, TimeSpan.FromSeconds(1), default(Func<int, int>)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => s.SchedulePeriodic(42, TimeSpan.Zero, x => x));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => s.SchedulePeriodic(42, TimeSpan.FromMilliseconds(1).Subtract(TimeSpan.FromTicks(1)), x => x));
- }
- [TestMethod]
- public void SchedulePeriodic()
- {
- using (WinFormsTestUtils.RunTest(out var lbl))
- {
- var evt = new ManualResetEvent(false);
- var id = Thread.CurrentThread.ManagedThreadId;
- var sch = new ControlScheduler(lbl);
- var d = new SingleAssignmentDisposable();
- d.Disposable = sch.SchedulePeriodic(1, TimeSpan.FromSeconds(0.1), n =>
- {
- lbl.Text = "Okay " + n;
- Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
- if (n == 3)
- {
- d.Dispose();
- sch.Schedule(TimeSpan.FromSeconds(0.2), () =>
- {
- Assert.Equal("Okay 3", lbl.Text);
- Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
- evt.Set();
- });
- }
- if (n > 3)
- {
- Assert.True(false);
- }
- return n + 1;
- });
- evt.WaitOne();
- }
- }
- [TestMethod]
- public void SchedulePeriodic_Nested()
- {
- using (WinFormsTestUtils.RunTest(out var lbl))
- {
- var evt = new ManualResetEvent(false);
- var id = Thread.CurrentThread.ManagedThreadId;
- var sch = new ControlScheduler(lbl);
- sch.Schedule(() =>
- {
- lbl.Text = "Okay";
- var d = new SingleAssignmentDisposable();
- d.Disposable = sch.SchedulePeriodic(1, TimeSpan.FromSeconds(0.1), n =>
- {
- lbl.Text = "Okay " + n;
- Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
- if (n == 3)
- {
- d.Dispose();
- sch.Schedule(TimeSpan.FromSeconds(0.2), () =>
- {
- Assert.Equal("Okay 3", lbl.Text);
- Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
- evt.Set();
- });
- }
- return n + 1;
- });
- });
- evt.WaitOne();
- }
- }
- }
- }
- #endif
|