ToDictionaryTest.cs 7.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223
  1. // Licensed to the .NET Foundation under one or more agreements.
  2. // The .NET Foundation licenses this file to you under the Apache 2.0 License.
  3. // See the LICENSE file in the project root for more information.
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Linq;
  7. using System.Reactive.Linq;
  8. using Microsoft.Reactive.Testing;
  9. using ReactiveTests.Dummies;
  10. using Xunit;
  11. namespace ReactiveTests.Tests
  12. {
  13. public class ToDictionaryTest : ReactiveTest
  14. {
  15. [Fact]
  16. public void ToDictionary_ArgumentChecking()
  17. {
  18. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToDictionary(null, DummyFunc<int, int>.Instance, EqualityComparer<int>.Default));
  19. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToDictionary(DummyObservable<int>.Instance, null, EqualityComparer<int>.Default));
  20. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToDictionary(DummyObservable<int>.Instance, DummyFunc<int, int>.Instance, null));
  21. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToDictionary(null, DummyFunc<int, int>.Instance));
  22. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToDictionary<int, int>(DummyObservable<int>.Instance, null));
  23. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToDictionary(null, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, EqualityComparer<int>.Default));
  24. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToDictionary(DummyObservable<int>.Instance, null, DummyFunc<int, int>.Instance, EqualityComparer<int>.Default));
  25. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToDictionary<int, int, int>(DummyObservable<int>.Instance, DummyFunc<int, int>.Instance, null, EqualityComparer<int>.Default));
  26. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToDictionary(DummyObservable<int>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, null));
  27. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToDictionary(null, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance));
  28. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToDictionary<int, int, int>(DummyObservable<int>.Instance, null, DummyFunc<int, int>.Instance));
  29. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.ToDictionary<int, int, int>(DummyObservable<int>.Instance, DummyFunc<int, int>.Instance, null));
  30. }
  31. [Fact]
  32. public void ToDictionary_Completed()
  33. {
  34. var scheduler = new TestScheduler();
  35. var xs = scheduler.CreateHotObservable(
  36. OnNext(110, 1),
  37. OnNext(220, 2),
  38. OnNext(330, 3),
  39. OnNext(440, 4),
  40. OnNext(550, 5),
  41. OnCompleted<int>(660)
  42. );
  43. var res = scheduler.Start(() =>
  44. xs.ToDictionary(x => x * 2, x => x * 4, EqualityComparer<int>.Default)
  45. );
  46. res.Messages.AssertEqual(
  47. OnNext<IDictionary<int, int>>(660, d =>
  48. {
  49. return d.Count == 4
  50. && d[4] == 8
  51. && d[6] == 12
  52. && d[8] == 16
  53. && d[10] == 20;
  54. }),
  55. OnCompleted<IDictionary<int, int>>(660)
  56. );
  57. xs.Subscriptions.AssertEqual(
  58. Subscribe(200, 660)
  59. );
  60. }
  61. [Fact]
  62. public void ToDictionary_Error()
  63. {
  64. var scheduler = new TestScheduler();
  65. var ex = new Exception();
  66. var xs = scheduler.CreateHotObservable(
  67. OnNext(110, 1),
  68. OnNext(220, 2),
  69. OnNext(330, 3),
  70. OnNext(440, 4),
  71. OnNext(550, 5),
  72. OnError<int>(660, ex)
  73. );
  74. var res = scheduler.Start(() =>
  75. xs.ToDictionary(x => x * 2, x => x * 4, EqualityComparer<int>.Default)
  76. );
  77. res.Messages.AssertEqual(
  78. OnError<IDictionary<int, int>>(660, ex)
  79. );
  80. xs.Subscriptions.AssertEqual(
  81. Subscribe(200, 660)
  82. );
  83. }
  84. [Fact]
  85. public void ToDictionary_KeySelectorThrows()
  86. {
  87. var scheduler = new TestScheduler();
  88. var ex = new Exception();
  89. var xs = scheduler.CreateHotObservable(
  90. OnNext(110, 1),
  91. OnNext(220, 2),
  92. OnNext(330, 3),
  93. OnNext(440, 4),
  94. OnNext(550, 5),
  95. OnCompleted<int>(600)
  96. );
  97. var res = scheduler.Start(() =>
  98. xs.ToDictionary(x => { if (x < 4) { return x * 2; } throw ex; }, x => x * 4, EqualityComparer<int>.Default)
  99. );
  100. res.Messages.AssertEqual(
  101. OnError<IDictionary<int, int>>(440, ex)
  102. );
  103. xs.Subscriptions.AssertEqual(
  104. Subscribe(200, 440)
  105. );
  106. }
  107. [Fact]
  108. public void ToDictionary_ElementSelectorThrows()
  109. {
  110. var scheduler = new TestScheduler();
  111. var ex = new Exception();
  112. var xs = scheduler.CreateHotObservable(
  113. OnNext(110, 1),
  114. OnNext(220, 2),
  115. OnNext(330, 3),
  116. OnNext(440, 4),
  117. OnNext(550, 5),
  118. OnCompleted<int>(600)
  119. );
  120. var res = scheduler.Start(() =>
  121. xs.ToDictionary(x => x * 2, x => { if (x < 4) { return x * 4; } throw ex; }, EqualityComparer<int>.Default)
  122. );
  123. res.Messages.AssertEqual(
  124. OnError<IDictionary<int, int>>(440, ex)
  125. );
  126. xs.Subscriptions.AssertEqual(
  127. Subscribe(200, 440)
  128. );
  129. }
  130. [Fact]
  131. public void ToDictionary_Disposed()
  132. {
  133. var scheduler = new TestScheduler();
  134. var xs = scheduler.CreateHotObservable(
  135. OnNext(110, 1),
  136. OnNext(220, 2),
  137. OnNext(330, 3),
  138. OnNext(440, 4),
  139. OnNext(550, 5)
  140. );
  141. var res = scheduler.Start(() =>
  142. xs.ToDictionary(x => x * 2, x => x * 4, EqualityComparer<int>.Default)
  143. );
  144. res.Messages.AssertEqual(
  145. );
  146. xs.Subscriptions.AssertEqual(
  147. Subscribe(200, 1000)
  148. );
  149. }
  150. [Fact]
  151. public void ToDictionary_MultipleAdd()
  152. {
  153. var scheduler = new TestScheduler();
  154. var xs = scheduler.CreateHotObservable(
  155. OnNext(110, 1),
  156. OnNext(220, 2),
  157. OnNext(330, 3),
  158. OnNext(440, 4),
  159. OnNext(550, 5),
  160. OnCompleted<int>(660)
  161. );
  162. var res = scheduler.Start(() =>
  163. xs.ToDictionary(x => x % 2, x => x * 2, EqualityComparer<int>.Default)
  164. );
  165. res.Messages.AssertEqual(
  166. OnError<IDictionary<int, int>>(440, e => true)
  167. );
  168. xs.Subscriptions.AssertEqual(
  169. Subscribe(200, 440)
  170. );
  171. }
  172. [Fact]
  173. public void ToDictionary_Default()
  174. {
  175. var d1 = Observable.Range(1, 10).ToDictionary(x => x.ToString()).First();
  176. Assert.Equal(7, d1["7"]);
  177. var d2 = Observable.Range(1, 10).ToDictionary(x => x.ToString(), x => x * 2).First();
  178. Assert.Equal(18, d2["9"]);
  179. var d3 = Observable.Range(1, 10).ToDictionary(x => x.ToString(), EqualityComparer<string>.Default).First();
  180. Assert.Equal(7, d3["7"]);
  181. }
  182. }
  183. }