LastOrDefaultAsyncTest.cs 6.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235
  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.Reactive.Linq;
  6. using Microsoft.Reactive.Testing;
  7. using ReactiveTests.Dummies;
  8. using Xunit;
  9. namespace ReactiveTests.Tests
  10. {
  11. public class LastOrDefaultAsyncTest : ReactiveTest
  12. {
  13. [Fact]
  14. public void LastOrDefaultAsync_ArgumentChecking()
  15. {
  16. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.LastOrDefaultAsync(default(IObservable<int>)));
  17. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.LastOrDefaultAsync(default(IObservable<int>), _ => true));
  18. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.LastOrDefaultAsync(DummyObservable<int>.Instance, default));
  19. }
  20. [Fact]
  21. public void LastOrDefaultAsync_Empty()
  22. {
  23. var scheduler = new TestScheduler();
  24. var xs = scheduler.CreateHotObservable(
  25. OnNext(150, 1),
  26. OnCompleted<int>(250)
  27. );
  28. var res = scheduler.Start(() =>
  29. xs.LastOrDefaultAsync()
  30. );
  31. res.Messages.AssertEqual(
  32. OnNext(250, 0),
  33. OnCompleted<int>(250)
  34. );
  35. xs.Subscriptions.AssertEqual(
  36. Subscribe(200, 250)
  37. );
  38. }
  39. [Fact]
  40. public void LastOrDefaultAsync_One()
  41. {
  42. var scheduler = new TestScheduler();
  43. var xs = scheduler.CreateHotObservable(
  44. OnNext(150, 1),
  45. OnNext(210, 2),
  46. OnCompleted<int>(250)
  47. );
  48. var res = scheduler.Start(() =>
  49. xs.LastOrDefaultAsync()
  50. );
  51. res.Messages.AssertEqual(
  52. OnNext(250, 2),
  53. OnCompleted<int>(250)
  54. );
  55. xs.Subscriptions.AssertEqual(
  56. Subscribe(200, 250)
  57. );
  58. }
  59. [Fact]
  60. public void LastOrDefaultAsync_Many()
  61. {
  62. var scheduler = new TestScheduler();
  63. var xs = scheduler.CreateHotObservable(
  64. OnNext(150, 1),
  65. OnNext(210, 2),
  66. OnNext(220, 3),
  67. OnCompleted<int>(250)
  68. );
  69. var res = scheduler.Start(() =>
  70. xs.LastOrDefaultAsync()
  71. );
  72. res.Messages.AssertEqual(
  73. OnNext(250, 3),
  74. OnCompleted<int>(250)
  75. );
  76. xs.Subscriptions.AssertEqual(
  77. Subscribe(200, 250)
  78. );
  79. }
  80. [Fact]
  81. public void LastOrDefaultAsync_Error()
  82. {
  83. var scheduler = new TestScheduler();
  84. var ex = new Exception();
  85. var xs = scheduler.CreateHotObservable(
  86. OnNext(150, 1),
  87. OnError<int>(210, ex)
  88. );
  89. var res = scheduler.Start(() =>
  90. xs.LastOrDefaultAsync()
  91. );
  92. res.Messages.AssertEqual(
  93. OnError<int>(210, ex)
  94. );
  95. xs.Subscriptions.AssertEqual(
  96. Subscribe(200, 210)
  97. );
  98. }
  99. [Fact]
  100. public void LastOrDefaultAsync_Predicate()
  101. {
  102. var scheduler = new TestScheduler();
  103. var xs = scheduler.CreateHotObservable(
  104. OnNext(150, 1),
  105. OnNext(210, 2),
  106. OnNext(220, 3),
  107. OnNext(230, 4),
  108. OnNext(240, 5),
  109. OnCompleted<int>(250)
  110. );
  111. var res = scheduler.Start(() =>
  112. xs.LastOrDefaultAsync(x => x % 2 == 1)
  113. );
  114. res.Messages.AssertEqual(
  115. OnNext(250, 5),
  116. OnCompleted<int>(250)
  117. );
  118. xs.Subscriptions.AssertEqual(
  119. Subscribe(200, 250)
  120. );
  121. }
  122. [Fact]
  123. public void LastOrDefaultAsync_Predicate_None()
  124. {
  125. var scheduler = new TestScheduler();
  126. var xs = scheduler.CreateHotObservable(
  127. OnNext(150, 1),
  128. OnNext(210, 2),
  129. OnNext(220, 3),
  130. OnNext(230, 4),
  131. OnNext(240, 5),
  132. OnCompleted<int>(250)
  133. );
  134. var res = scheduler.Start(() =>
  135. xs.LastOrDefaultAsync(x => x > 10)
  136. );
  137. res.Messages.AssertEqual(
  138. OnNext(250, 0),
  139. OnCompleted<int>(250)
  140. );
  141. xs.Subscriptions.AssertEqual(
  142. Subscribe(200, 250)
  143. );
  144. }
  145. [Fact]
  146. public void LastOrDefaultAsync_Predicate_Throw()
  147. {
  148. var scheduler = new TestScheduler();
  149. var ex = new Exception();
  150. var xs = scheduler.CreateHotObservable(
  151. OnNext(150, 1),
  152. OnError<int>(210, ex)
  153. );
  154. var res = scheduler.Start(() =>
  155. xs.LastOrDefaultAsync(x => x > 10)
  156. );
  157. res.Messages.AssertEqual(
  158. OnError<int>(210, ex)
  159. );
  160. xs.Subscriptions.AssertEqual(
  161. Subscribe(200, 210)
  162. );
  163. }
  164. [Fact]
  165. public void LastOrDefaultAsync_PredicateThrows()
  166. {
  167. var scheduler = new TestScheduler();
  168. var ex = new Exception();
  169. var xs = scheduler.CreateHotObservable(
  170. OnNext(150, 1),
  171. OnNext(210, 2),
  172. OnNext(220, 3),
  173. OnNext(230, 4),
  174. OnNext(240, 5),
  175. OnCompleted<int>(250)
  176. );
  177. var res = scheduler.Start(() =>
  178. xs.LastOrDefaultAsync(x => { if (x < 4) { return x % 2 == 1; } throw ex; })
  179. );
  180. res.Messages.AssertEqual(
  181. OnError<int>(230, ex)
  182. );
  183. xs.Subscriptions.AssertEqual(
  184. Subscribe(200, 230)
  185. );
  186. }
  187. }
  188. }