AppendPrependTest.cs 9.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357
  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.Concurrency;
  6. using System.Reactive.Linq;
  7. using Microsoft.Reactive.Testing;
  8. using Xunit;
  9. namespace ReactiveTests.Tests
  10. {
  11. public class AppendPrependTest : ReactiveTest
  12. {
  13. [Fact]
  14. public void AppendPrepend()
  15. {
  16. var scheduler = new TestScheduler();
  17. var xs = scheduler.CreateHotObservable(
  18. OnNext(150, 1),
  19. OnNext(220, 2),
  20. OnCompleted<int>(250)
  21. );
  22. var res = scheduler.Start(() =>
  23. xs.Append(3).Prepend(4)
  24. );
  25. res.Messages.AssertEqual(
  26. OnNext(200, 4),
  27. OnNext(220, 2),
  28. OnNext(250, 3),
  29. OnCompleted<int>(250)
  30. );
  31. }
  32. [Fact]
  33. public void PrependAppend()
  34. {
  35. var scheduler = new TestScheduler();
  36. var xs = scheduler.CreateHotObservable(
  37. OnNext(150, 1),
  38. OnNext(220, 2),
  39. OnCompleted<int>(250)
  40. );
  41. var res = scheduler.Start(() =>
  42. xs.Prepend(4).Append(3)
  43. );
  44. res.Messages.AssertEqual(
  45. OnNext(200, 4),
  46. OnNext(220, 2),
  47. OnNext(250, 3),
  48. OnCompleted<int>(250)
  49. );
  50. }
  51. [Fact]
  52. public void AppendPrepend_Scheduler()
  53. {
  54. var scheduler = new TestScheduler();
  55. var xs = scheduler.CreateHotObservable(
  56. OnNext(150, 1),
  57. OnNext(220, 2),
  58. OnCompleted<int>(250)
  59. );
  60. var res = scheduler.Start(() =>
  61. xs.Append(3, scheduler).Prepend(4, scheduler)
  62. );
  63. res.Messages.AssertEqual(
  64. OnNext(201, 4),
  65. OnNext(220, 2),
  66. OnNext(251, 3),
  67. OnCompleted<int>(251)
  68. );
  69. }
  70. [Fact]
  71. public void PrependAppend_Scheduler()
  72. {
  73. var scheduler = new TestScheduler();
  74. var xs = scheduler.CreateHotObservable(
  75. OnNext(150, 1),
  76. OnNext(220, 2),
  77. OnCompleted<int>(250)
  78. );
  79. var res = scheduler.Start(() =>
  80. xs.Prepend(4, scheduler).Append(3, scheduler)
  81. );
  82. res.Messages.AssertEqual(
  83. OnNext(201, 4),
  84. OnNext(220, 2),
  85. OnNext(251, 3),
  86. OnCompleted<int>(251)
  87. );
  88. }
  89. [Fact]
  90. public void AppendPrepend_Many()
  91. {
  92. var scheduler = new TestScheduler();
  93. var xs = scheduler.CreateHotObservable(
  94. OnNext(150, 1),
  95. OnNext(220, 2),
  96. OnCompleted<int>(250)
  97. );
  98. var res = scheduler.Start(() =>
  99. xs.Append(3).Append(4).Append(5).Prepend(6).Prepend(7).Prepend(8)
  100. );
  101. res.Messages.AssertEqual(
  102. OnNext(200, 8),
  103. OnNext(200, 7),
  104. OnNext(200, 6),
  105. OnNext(220, 2),
  106. OnNext(250, 3),
  107. OnNext(250, 4),
  108. OnNext(250, 5),
  109. OnCompleted<int>(250)
  110. );
  111. }
  112. [Fact]
  113. public void PrependAppend_Many()
  114. {
  115. var scheduler = new TestScheduler();
  116. var xs = scheduler.CreateHotObservable(
  117. OnNext(150, 1),
  118. OnNext(220, 2),
  119. OnCompleted<int>(250)
  120. );
  121. var res = scheduler.Start(() =>
  122. xs.Prepend(6).Prepend(7).Prepend(8).Append(3).Append(4).Append(5)
  123. );
  124. res.Messages.AssertEqual(
  125. OnNext(200, 8),
  126. OnNext(200, 7),
  127. OnNext(200, 6),
  128. OnNext(220, 2),
  129. OnNext(250, 3),
  130. OnNext(250, 4),
  131. OnNext(250, 5),
  132. OnCompleted<int>(250)
  133. );
  134. }
  135. [Fact]
  136. public void AppendPrepend_Many_Scheduler()
  137. {
  138. var scheduler = new TestScheduler();
  139. var xs = scheduler.CreateHotObservable(
  140. OnNext(150, 1),
  141. OnNext(220, 2),
  142. OnCompleted<int>(250)
  143. );
  144. var res = scheduler.Start(() =>
  145. xs.Append(3, scheduler)
  146. .Append(4, scheduler)
  147. .Append(5, scheduler)
  148. .Prepend(6, scheduler)
  149. .Prepend(7, scheduler)
  150. .Prepend(8, scheduler)
  151. );
  152. res.Messages.AssertEqual(
  153. OnNext(201, 8),
  154. OnNext(202, 7),
  155. OnNext(203, 6),
  156. OnNext(220, 2),
  157. OnNext(251, 3),
  158. OnNext(252, 4),
  159. OnNext(253, 5),
  160. OnCompleted<int>(253)
  161. );
  162. }
  163. [Fact]
  164. public void PrependAppend_Many_Scheduler()
  165. {
  166. var scheduler = new TestScheduler();
  167. var xs = scheduler.CreateHotObservable(
  168. OnNext(150, 1),
  169. OnNext(220, 2),
  170. OnCompleted<int>(250)
  171. );
  172. var res = scheduler.Start(() =>
  173. xs.Prepend(6, scheduler)
  174. .Prepend(7, scheduler)
  175. .Prepend(8, scheduler)
  176. .Append(3, scheduler)
  177. .Append(4, scheduler)
  178. .Append(5, scheduler)
  179. );
  180. res.Messages.AssertEqual(
  181. OnNext(201, 8),
  182. OnNext(202, 7),
  183. OnNext(203, 6),
  184. OnNext(220, 2),
  185. OnNext(251, 3),
  186. OnNext(252, 4),
  187. OnNext(253, 5),
  188. OnCompleted<int>(253)
  189. );
  190. }
  191. [Fact]
  192. public void AppendPrepend_Mixed()
  193. {
  194. var scheduler = new TestScheduler();
  195. var xs = scheduler.CreateHotObservable(
  196. OnNext(150, 1),
  197. OnNext(220, 2),
  198. OnCompleted<int>(250)
  199. );
  200. var res = scheduler.Start(() =>
  201. xs.Append(3).Prepend(6).Append(4).Prepend(7).Prepend(8).Append(5)
  202. );
  203. res.Messages.AssertEqual(
  204. OnNext(200, 8),
  205. OnNext(200, 7),
  206. OnNext(200, 6),
  207. OnNext(220, 2),
  208. OnNext(250, 3),
  209. OnNext(250, 4),
  210. OnNext(250, 5),
  211. OnCompleted<int>(250)
  212. );
  213. }
  214. [Fact]
  215. public void AppendPrepend_Mixed_Scheduler()
  216. {
  217. var scheduler = new TestScheduler();
  218. var xs = scheduler.CreateHotObservable(
  219. OnNext(150, 1),
  220. OnNext(220, 2),
  221. OnCompleted<int>(250)
  222. );
  223. var res = scheduler.Start(() =>
  224. xs.Append(3, scheduler)
  225. .Prepend(6, scheduler)
  226. .Append(4, scheduler)
  227. .Prepend(7, scheduler)
  228. .Prepend(8, scheduler)
  229. .Append(5, scheduler)
  230. );
  231. res.Messages.AssertEqual(
  232. OnNext(201, 8),
  233. OnNext(202, 7),
  234. OnNext(203, 6),
  235. OnNext(220, 2),
  236. OnNext(251, 3),
  237. OnNext(252, 4),
  238. OnNext(253, 5),
  239. OnCompleted<int>(253)
  240. );
  241. }
  242. [Fact]
  243. public void AppendPrepend_MixedSchedulers()
  244. {
  245. var scheduler = new TestScheduler();
  246. var xs = scheduler.CreateHotObservable(
  247. OnNext(150, 1),
  248. OnNext(220, 2),
  249. OnCompleted<int>(250)
  250. );
  251. var res = scheduler.Start(() =>
  252. xs.Append(3, scheduler)
  253. .Prepend(6)
  254. .Append(4, scheduler)
  255. .Prepend(7)
  256. .Prepend(8, scheduler)
  257. .Append(5)
  258. );
  259. res.Messages.AssertEqual(
  260. OnNext(201, 8),
  261. OnNext(201, 7),
  262. OnNext(201, 6),
  263. OnNext(220, 2),
  264. OnNext(251, 3),
  265. OnNext(252, 4),
  266. OnNext(252, 5),
  267. OnCompleted<int>(252)
  268. );
  269. }
  270. [Fact]
  271. public void AppendPrepend_SchedulerRecursive()
  272. {
  273. var scheduler = new EventLoopScheduler();
  274. var source = Observable.Range(1, 1000).DelaySubscription(TimeSpan.FromMilliseconds(100), ThreadPoolScheduler.Instance);
  275. var result = source.Prepend(0, scheduler).Prepend(-1, scheduler)
  276. .Timeout(TimeSpan.FromSeconds(5))
  277. .ToList().First();
  278. Assert.Equal(1002, result.Count);
  279. var j = 0;
  280. for (var i = -1; i <= 1000; i++)
  281. {
  282. Assert.Equal(i, result[j++]);
  283. }
  284. }
  285. [Fact]
  286. public void AppendPrepend_SchedulerLongRunning()
  287. {
  288. var scheduler = NewThreadScheduler.Default;
  289. Assert.True(scheduler is ISchedulerLongRunning, "Not a long-running scheduler!");
  290. var source = Observable.Range(1, 1000).DelaySubscription(TimeSpan.FromMilliseconds(100), ThreadPoolScheduler.Instance);
  291. var result = source.Prepend(0, scheduler).Prepend(-1, scheduler)
  292. .Timeout(TimeSpan.FromSeconds(5))
  293. .ToList().First();
  294. Assert.Equal(1002, result.Count);
  295. var j = 0;
  296. for (var i = -1; i <= 1000; i++)
  297. {
  298. Assert.Equal(i, result[j++]);
  299. }
  300. }
  301. }
  302. }