1
0

LastAsyncTest.cs 5.9 KB

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