DoWhileTest.cs 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228
  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.Text;
  8. using System.Threading.Tasks;
  9. using System.Reactive;
  10. using System.Reactive.Concurrency;
  11. using System.Reactive.Linq;
  12. using Microsoft.Reactive.Testing;
  13. using Xunit;
  14. using ReactiveTests.Dummies;
  15. using System.Reflection;
  16. using System.Threading;
  17. using System.Reactive.Disposables;
  18. using System.Reactive.Subjects;
  19. namespace ReactiveTests.Tests
  20. {
  21. public class DoWhileTest : ReactiveTest
  22. {
  23. [Fact]
  24. public void DoWhile_ArgumentChecking()
  25. {
  26. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.DoWhile(DummyObservable<int>.Instance, null));
  27. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.DoWhile(default(IObservable<int>), DummyFunc<bool>.Instance));
  28. }
  29. [Fact]
  30. public void DoWhile_AlwaysFalse()
  31. {
  32. var scheduler = new TestScheduler();
  33. var xs = scheduler.CreateColdObservable(
  34. OnNext(50, 1),
  35. OnNext(100, 2),
  36. OnNext(150, 3),
  37. OnNext(200, 4),
  38. OnCompleted<int>(250)
  39. );
  40. var results = scheduler.Start(() => Observable.DoWhile(xs, () => false));
  41. results.Messages.AssertEqual(
  42. OnNext(250, 1),
  43. OnNext(300, 2),
  44. OnNext(350, 3),
  45. OnNext(400, 4),
  46. OnCompleted<int>(450)
  47. );
  48. xs.Subscriptions.AssertEqual(
  49. Subscribe(200, 450)
  50. );
  51. }
  52. [Fact]
  53. public void DoWhile_AlwaysTrue()
  54. {
  55. var scheduler = new TestScheduler();
  56. var xs = scheduler.CreateColdObservable(
  57. OnNext(50, 1),
  58. OnNext(100, 2),
  59. OnNext(150, 3),
  60. OnNext(200, 4),
  61. OnCompleted<int>(250)
  62. );
  63. var results = scheduler.Start(() => Observable.DoWhile(xs, () => true));
  64. results.Messages.AssertEqual(
  65. OnNext(250, 1),
  66. OnNext(300, 2),
  67. OnNext(350, 3),
  68. OnNext(400, 4),
  69. OnNext(500, 1),
  70. OnNext(550, 2),
  71. OnNext(600, 3),
  72. OnNext(650, 4),
  73. OnNext(750, 1),
  74. OnNext(800, 2),
  75. OnNext(850, 3),
  76. OnNext(900, 4)
  77. );
  78. xs.Subscriptions.AssertEqual(
  79. Subscribe(200, 450),
  80. Subscribe(450, 700),
  81. Subscribe(700, 950),
  82. Subscribe(950, 1000)
  83. );
  84. }
  85. [Fact]
  86. public void DoWhile_AlwaysTrue_Throw()
  87. {
  88. var scheduler = new TestScheduler();
  89. var ex = new Exception();
  90. var xs = scheduler.CreateColdObservable(
  91. OnError<int>(50, ex)
  92. );
  93. var results = scheduler.Start(() => Observable.DoWhile(xs, () => true));
  94. results.Messages.AssertEqual(
  95. OnError<int>(250, ex)
  96. );
  97. xs.Subscriptions.AssertEqual(
  98. Subscribe(200, 250)
  99. );
  100. }
  101. [Fact]
  102. public void DoWhile_AlwaysTrue_Infinite()
  103. {
  104. var scheduler = new TestScheduler();
  105. var xs = scheduler.CreateColdObservable(
  106. OnNext(50, 1)
  107. );
  108. var results = scheduler.Start(() => Observable.DoWhile(xs, () => true));
  109. results.Messages.AssertEqual(
  110. OnNext(250, 1)
  111. );
  112. xs.Subscriptions.AssertEqual(
  113. Subscribe(200, 1000)
  114. );
  115. }
  116. [Fact]
  117. public void DoWhile_SometimesTrue()
  118. {
  119. var scheduler = new TestScheduler();
  120. var xs = scheduler.CreateColdObservable(
  121. OnNext(50, 1),
  122. OnNext(100, 2),
  123. OnNext(150, 3),
  124. OnNext(200, 4),
  125. OnCompleted<int>(250)
  126. );
  127. int n = 0;
  128. var results = scheduler.Start(() => Observable.DoWhile(xs, () => ++n < 3));
  129. results.Messages.AssertEqual(
  130. OnNext(250, 1),
  131. OnNext(300, 2),
  132. OnNext(350, 3),
  133. OnNext(400, 4),
  134. OnNext(500, 1),
  135. OnNext(550, 2),
  136. OnNext(600, 3),
  137. OnNext(650, 4),
  138. OnNext(750, 1),
  139. OnNext(800, 2),
  140. OnNext(850, 3),
  141. OnNext(900, 4),
  142. OnCompleted<int>(950)
  143. );
  144. xs.Subscriptions.AssertEqual(
  145. Subscribe(200, 450),
  146. Subscribe(450, 700),
  147. Subscribe(700, 950)
  148. );
  149. }
  150. [Fact]
  151. public void DoWhile_SometimesThrows()
  152. {
  153. var scheduler = new TestScheduler();
  154. var xs = scheduler.CreateColdObservable(
  155. OnNext(50, 1),
  156. OnNext(100, 2),
  157. OnNext(150, 3),
  158. OnNext(200, 4),
  159. OnCompleted<int>(250)
  160. );
  161. int n = 0;
  162. var ex = new Exception();
  163. var results = scheduler.Start(() => Observable.DoWhile(xs, () => ++n < 3 ? true : Throw<bool>(ex)));
  164. results.Messages.AssertEqual(
  165. OnNext(250, 1),
  166. OnNext(300, 2),
  167. OnNext(350, 3),
  168. OnNext(400, 4),
  169. OnNext(500, 1),
  170. OnNext(550, 2),
  171. OnNext(600, 3),
  172. OnNext(650, 4),
  173. OnNext(750, 1),
  174. OnNext(800, 2),
  175. OnNext(850, 3),
  176. OnNext(900, 4),
  177. OnError<int>(950, ex)
  178. );
  179. xs.Subscriptions.AssertEqual(
  180. Subscribe(200, 450),
  181. Subscribe(450, 700),
  182. Subscribe(700, 950)
  183. );
  184. }
  185. static T Throw<T>(Exception ex)
  186. {
  187. throw ex;
  188. }
  189. }
  190. }