123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347 |
- // 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.
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Reactive;
- using System.Reactive.Linq;
- using System.Reactive.Subjects;
- using System.Reflection;
- using Microsoft.Reactive.Testing;
- using Microsoft.VisualStudio.TestTools.UnitTesting;
- using Assert = Xunit.Assert;
- namespace ReactiveTests.Tests
- {
- [TestClass]
- public class ToEventPatternTest : ReactiveTest
- {
- [TestMethod]
- public void ToEventPattern_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToEventPattern<EventArgs>(null));
- }
- [TestMethod]
- public void ToEventPattern_IEvent()
- {
- var src = new Subject<EventPattern<EventArgs<int>>>();
- var evt = src.ToEventPattern();
- var snd = new object();
- var lst = new List<int>();
- var hnd = new EventHandler<EventArgs<int>>((s, e) =>
- {
- Assert.Same(snd, s);
- lst.Add(e.Value);
- });
- evt.OnNext += hnd;
- src.OnNext(new EventPattern<EventArgs<int>>(snd, new EventArgs<int>(42)));
- src.OnNext(new EventPattern<EventArgs<int>>(snd, new EventArgs<int>(43)));
- evt.OnNext -= hnd;
- src.OnNext(new EventPattern<EventArgs<int>>(snd, new EventArgs<int>(44)));
- Assert.True(lst.SequenceEqual([42, 43]));
- }
- [TestMethod]
- public void ToEventPattern_IEvent_Fails()
- {
- var src = new Subject<EventPattern<EventArgs<int>>>();
- var evt = src.ToEventPattern();
- var snd = new object();
- var lst = new List<int>();
- var hnd = new EventHandler<EventArgs<int>>((s, e) =>
- {
- Assert.Same(snd, s);
- lst.Add(e.Value);
- });
- evt.OnNext += hnd;
- src.OnNext(new EventPattern<EventArgs<int>>(snd, new EventArgs<int>(42)));
- src.OnNext(new EventPattern<EventArgs<int>>(snd, new EventArgs<int>(43)));
- var ex = new Exception();
- ReactiveAssert.Throws(ex, () => src.OnError(ex));
- Assert.True(lst.SequenceEqual([42, 43]));
- }
- [TestMethod]
- public void ToEventPattern_IEvent_Completes()
- {
- var src = new Subject<EventPattern<EventArgs<int>>>();
- var evt = src.ToEventPattern();
- var snd = new object();
- var lst = new List<int>();
- var hnd = new EventHandler<EventArgs<int>>((s, e) =>
- {
- Assert.Same(snd, s);
- lst.Add(e.Value);
- });
- evt.OnNext += hnd;
- src.OnNext(new EventPattern<EventArgs<int>>(snd, new EventArgs<int>(42)));
- src.OnNext(new EventPattern<EventArgs<int>>(snd, new EventArgs<int>(43)));
- src.OnCompleted();
- Assert.True(lst.SequenceEqual([42, 43]));
- }
- private class EventSrc
- {
- public event EventHandler<EventArgs<string>> E;
- public void On(string s)
- {
- E?.Invoke(this, new EventArgs<string>(s));
- }
- }
- private class EventArgs<T> : EventArgs
- {
- public T Value { get; private set; }
- public EventArgs(T value)
- {
- Value = value;
- }
- }
- [TestMethod]
- public void FromEventPattern_ToEventPattern()
- {
- var src = new EventSrc();
- var evt = Observable.FromEventPattern<EventHandler<EventArgs<string>>, EventArgs<string>>(h => new EventHandler<EventArgs<string>>(h), h => src.E += h, h => src.E -= h);
- var res = evt.ToEventPattern();
- var lst = new List<string>();
- var hnd = new EventHandler<EventArgs<string>>((s, e) =>
- {
- Assert.Same(src, s);
- lst.Add(e.Value);
- });
- src.On("bar");
- res.OnNext += hnd;
- src.On("foo");
- src.On("baz");
- res.OnNext -= hnd;
- src.On("qux");
- Assert.True(lst.SequenceEqual(["foo", "baz"]));
- }
- [TestMethod]
- public void ToEvent_DuplicateHandlers()
- {
- var src = new Subject<Unit>();
- var evt = src.ToEvent();
- var num = 0;
- var hnd = new Action<Unit>(e => num++);
- evt.OnNext += hnd;
- Assert.Equal(0, num);
- src.OnNext(new Unit());
- Assert.Equal(1, num);
- evt.OnNext += hnd;
- src.OnNext(new Unit());
- Assert.Equal(3, num);
- evt.OnNext -= hnd;
- src.OnNext(new Unit());
- Assert.Equal(4, num);
- evt.OnNext -= hnd;
- src.OnNext(new Unit());
- Assert.Equal(4, num);
- }
- [TestMethod]
- public void ToEvent_SourceCompletes()
- {
- var src = new Subject<Unit>();
- var evt = src.ToEvent();
- var num = 0;
- var hnd = new Action<Unit>(e => num++);
- evt.OnNext += hnd;
- Assert.Equal(0, num);
- src.OnNext(new Unit());
- Assert.Equal(1, num);
- src.OnNext(new Unit());
- Assert.Equal(2, num);
- src.OnCompleted();
- Assert.Equal(2, num);
- var tbl = GetSubscriptionTable(evt);
- Assert.True(tbl.Count == 0);
- }
- [TestMethod]
- public void ToEvent_SourceFails()
- {
- var src = new Subject<Unit>();
- var evt = src.ToEvent();
- var num = 0;
- var hnd = new Action<Unit>(e => num++);
- evt.OnNext += hnd;
- Assert.Equal(0, num);
- src.OnNext(new Unit());
- Assert.Equal(1, num);
- src.OnNext(new Unit());
- Assert.Equal(2, num);
- var ex = new Exception();
- ReactiveAssert.Throws(ex, () => src.OnError(ex));
- var tbl = GetSubscriptionTable(evt);
- Assert.True(tbl.Count == 0);
- }
- [TestMethod]
- public void ToEvent_DoneImmediately()
- {
- var src = Observable.Empty<Unit>();
- var evt = src.ToEvent();
- var num = 0;
- var hnd = new Action<Unit>(e => num++);
- for (var i = 0; i < 2; i++)
- {
- evt.OnNext += hnd;
- Assert.Equal(0, num);
- var tbl = GetSubscriptionTable(evt);
- Assert.True(tbl.Count == 0);
- }
- }
- [TestMethod]
- public void ToEvent_UnbalancedHandlers()
- {
- var src = new Subject<Unit>();
- var evt = src.ToEvent();
- var num = 0;
- var hnd = new Action<Unit>(e => num++);
- evt.OnNext += hnd;
- Assert.Equal(0, num);
- evt.OnNext -= hnd;
- Assert.Equal(0, num);
- evt.OnNext -= hnd;
- Assert.Equal(0, num);
- evt.OnNext += hnd;
- Assert.Equal(0, num);
- src.OnNext(new Unit());
- Assert.Equal(1, num);
- src.OnNext(new Unit());
- Assert.Equal(2, num);
- evt.OnNext -= hnd;
- Assert.Equal(2, num);
- src.OnNext(new Unit());
- Assert.Equal(2, num);
- }
- private static Dictionary<Delegate, Stack<IDisposable>> GetSubscriptionTable(object evt)
- {
- return (Dictionary<Delegate, Stack<IDisposable>>)evt.GetType().GetField("_subscriptions", BindingFlags.NonPublic | BindingFlags.Instance).GetValue(evt);
- }
- [TestMethod]
- public void EventPattern_Equality()
- {
- var e1 = new EventPattern<string, EventArgs>("Bart", EventArgs.Empty);
- var e2 = new EventPattern<string, EventArgs>("Bart", EventArgs.Empty);
- Assert.True(e1.Equals(e1));
- Assert.True(e1.Equals(e2));
- Assert.True(e2.Equals(e1));
- Assert.True(e1 == e2);
- Assert.True(!(e1 != e2));
- Assert.True(e1.GetHashCode() == e2.GetHashCode());
- Assert.False(e1.Equals(null));
- Assert.False(e1.Equals("xy"));
- Assert.False(e1 == null);
- }
- [TestMethod]
- public void EventPattern_Inequality()
- {
- var a1 = new MyEventArgs();
- var a2 = new MyEventArgs();
- var e1 = new EventPattern<string, MyEventArgs>("Bart", a1);
- var e2 = new EventPattern<string, MyEventArgs>("John", a1);
- var e3 = new EventPattern<string, MyEventArgs>("Bart", a2);
- Assert.True(!e1.Equals(e2));
- Assert.True(!e2.Equals(e1));
- Assert.True(!(e1 == e2));
- Assert.True(e1 != e2);
- Assert.True(e1.GetHashCode() != e2.GetHashCode());
- Assert.True(!e1.Equals(e3));
- Assert.True(!e3.Equals(e1));
- Assert.True(!(e1 == e3));
- Assert.True(e1 != e3);
- Assert.True(e1.GetHashCode() != e3.GetHashCode());
- }
- private class MyEventArgs : EventArgs
- {
- }
- }
- }
|