CaseTest.cs 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457
  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.Reactive.Concurrency;
  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 CaseTest : ReactiveTest
  14. {
  15. [Fact]
  16. public void Case_ArgumentChecking()
  17. {
  18. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Case(null, new Dictionary<int, IObservable<int>>(), DummyObservable<int>.Instance));
  19. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Case(DummyFunc<int>.Instance, null, DummyObservable<int>.Instance));
  20. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Case(DummyFunc<int>.Instance, new Dictionary<int, IObservable<int>>(), default(IObservable<int>)));
  21. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Case(null, new Dictionary<int, IObservable<int>>(), DummyScheduler.Instance));
  22. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Case<int, int>(DummyFunc<int>.Instance, null, DummyScheduler.Instance));
  23. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Case(DummyFunc<int>.Instance, new Dictionary<int, IObservable<int>>(), default(IScheduler)));
  24. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Case(null, new Dictionary<int, IObservable<int>>()));
  25. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Case<int, int>(DummyFunc<int>.Instance, null));
  26. }
  27. [Fact]
  28. public void Case_One()
  29. {
  30. var scheduler = new TestScheduler();
  31. var xs = scheduler.CreateHotObservable(
  32. OnNext(210, 1),
  33. OnNext(240, 2),
  34. OnNext(270, 3),
  35. OnCompleted<int>(300)
  36. );
  37. var ys = scheduler.CreateHotObservable(
  38. OnNext(220, 11),
  39. OnNext(250, 12),
  40. OnNext(280, 13),
  41. OnCompleted<int>(310)
  42. );
  43. var zs = scheduler.CreateHotObservable(
  44. OnNext(230, 21),
  45. OnNext(240, 22),
  46. OnNext(290, 23),
  47. OnCompleted<int>(320)
  48. );
  49. var map = new Dictionary<int, IObservable<int>>
  50. {
  51. { 1, xs },
  52. { 2, ys }
  53. };
  54. var results = scheduler.Start(() => Observable.Case(() => 1, map, zs));
  55. results.Messages.AssertEqual(
  56. OnNext(210, 1),
  57. OnNext(240, 2),
  58. OnNext(270, 3),
  59. OnCompleted<int>(300)
  60. );
  61. xs.Subscriptions.AssertEqual(
  62. Subscribe(200, 300)
  63. );
  64. ys.Subscriptions.AssertEqual(
  65. );
  66. zs.Subscriptions.AssertEqual(
  67. );
  68. }
  69. [Fact]
  70. public void Case_Two()
  71. {
  72. var scheduler = new TestScheduler();
  73. var xs = scheduler.CreateHotObservable(
  74. OnNext(210, 1),
  75. OnNext(240, 2),
  76. OnNext(270, 3),
  77. OnCompleted<int>(300)
  78. );
  79. var ys = scheduler.CreateHotObservable(
  80. OnNext(220, 11),
  81. OnNext(250, 12),
  82. OnNext(280, 13),
  83. OnCompleted<int>(310)
  84. );
  85. var zs = scheduler.CreateHotObservable(
  86. OnNext(230, 21),
  87. OnNext(240, 22),
  88. OnNext(290, 23),
  89. OnCompleted<int>(320)
  90. );
  91. var map = new Dictionary<int, IObservable<int>>
  92. {
  93. { 1, xs },
  94. { 2, ys }
  95. };
  96. var results = scheduler.Start(() => Observable.Case(() => 2, map, zs));
  97. results.Messages.AssertEqual(
  98. OnNext(220, 11),
  99. OnNext(250, 12),
  100. OnNext(280, 13),
  101. OnCompleted<int>(310)
  102. );
  103. xs.Subscriptions.AssertEqual(
  104. );
  105. ys.Subscriptions.AssertEqual(
  106. Subscribe(200, 310)
  107. );
  108. zs.Subscriptions.AssertEqual(
  109. );
  110. }
  111. [Fact]
  112. public void Case_Three()
  113. {
  114. var scheduler = new TestScheduler();
  115. var xs = scheduler.CreateHotObservable(
  116. OnNext(210, 1),
  117. OnNext(240, 2),
  118. OnNext(270, 3),
  119. OnCompleted<int>(300)
  120. );
  121. var ys = scheduler.CreateHotObservable(
  122. OnNext(220, 11),
  123. OnNext(250, 12),
  124. OnNext(280, 13),
  125. OnCompleted<int>(310)
  126. );
  127. var zs = scheduler.CreateHotObservable(
  128. OnNext(230, 21),
  129. OnNext(240, 22),
  130. OnNext(290, 23),
  131. OnCompleted<int>(320)
  132. );
  133. var map = new Dictionary<int, IObservable<int>>
  134. {
  135. { 1, xs },
  136. { 2, ys }
  137. };
  138. var results = scheduler.Start(() => Observable.Case(() => 3, map, zs));
  139. results.Messages.AssertEqual(
  140. OnNext(230, 21),
  141. OnNext(240, 22),
  142. OnNext(290, 23),
  143. OnCompleted<int>(320)
  144. );
  145. xs.Subscriptions.AssertEqual(
  146. );
  147. ys.Subscriptions.AssertEqual(
  148. );
  149. zs.Subscriptions.AssertEqual(
  150. Subscribe(200, 320)
  151. );
  152. }
  153. [Fact]
  154. public void Case_Throw()
  155. {
  156. var scheduler = new TestScheduler();
  157. var xs = scheduler.CreateHotObservable(
  158. OnNext(210, 1),
  159. OnNext(240, 2),
  160. OnNext(270, 3),
  161. OnCompleted<int>(300)
  162. );
  163. var ys = scheduler.CreateHotObservable(
  164. OnNext(220, 11),
  165. OnNext(250, 12),
  166. OnNext(280, 13),
  167. OnCompleted<int>(310)
  168. );
  169. var zs = scheduler.CreateHotObservable(
  170. OnNext(230, 21),
  171. OnNext(240, 22),
  172. OnNext(290, 23),
  173. OnCompleted<int>(320)
  174. );
  175. var map = new Dictionary<int, IObservable<int>>
  176. {
  177. { 1, xs },
  178. { 2, ys }
  179. };
  180. var ex = new Exception();
  181. var results = scheduler.Start(() => Observable.Case(() => Throw<int>(ex), map, zs));
  182. results.Messages.AssertEqual(
  183. OnError<int>(200, ex)
  184. );
  185. xs.Subscriptions.AssertEqual(
  186. );
  187. ys.Subscriptions.AssertEqual(
  188. );
  189. zs.Subscriptions.AssertEqual(
  190. );
  191. }
  192. [Fact]
  193. public void CaseWithDefault_One()
  194. {
  195. var scheduler = new TestScheduler();
  196. var xs = scheduler.CreateHotObservable(
  197. OnNext(210, 1),
  198. OnNext(240, 2),
  199. OnNext(270, 3),
  200. OnCompleted<int>(300)
  201. );
  202. var ys = scheduler.CreateHotObservable(
  203. OnNext(220, 11),
  204. OnNext(250, 12),
  205. OnNext(280, 13),
  206. OnCompleted<int>(310)
  207. );
  208. var map = new Dictionary<int, IObservable<int>>
  209. {
  210. { 1, xs },
  211. { 2, ys }
  212. };
  213. var results = scheduler.Start(() => Observable.Case(() => 1, map, scheduler));
  214. results.Messages.AssertEqual(
  215. OnNext(210, 1),
  216. OnNext(240, 2),
  217. OnNext(270, 3),
  218. OnCompleted<int>(300)
  219. );
  220. xs.Subscriptions.AssertEqual(
  221. Subscribe(200, 300)
  222. );
  223. ys.Subscriptions.AssertEqual(
  224. );
  225. }
  226. [Fact]
  227. public void CaseWithDefault_Two()
  228. {
  229. var scheduler = new TestScheduler();
  230. var xs = scheduler.CreateHotObservable(
  231. OnNext(210, 1),
  232. OnNext(240, 2),
  233. OnNext(270, 3),
  234. OnCompleted<int>(300)
  235. );
  236. var ys = scheduler.CreateHotObservable(
  237. OnNext(220, 11),
  238. OnNext(250, 12),
  239. OnNext(280, 13),
  240. OnCompleted<int>(310)
  241. );
  242. var map = new Dictionary<int, IObservable<int>>
  243. {
  244. { 1, xs },
  245. { 2, ys }
  246. };
  247. var results = scheduler.Start(() => Observable.Case(() => 2, map, scheduler));
  248. results.Messages.AssertEqual(
  249. OnNext(220, 11),
  250. OnNext(250, 12),
  251. OnNext(280, 13),
  252. OnCompleted<int>(310)
  253. );
  254. xs.Subscriptions.AssertEqual(
  255. );
  256. ys.Subscriptions.AssertEqual(
  257. Subscribe(200, 310)
  258. );
  259. }
  260. [Fact]
  261. public void CaseWithDefault_Three()
  262. {
  263. var scheduler = new TestScheduler();
  264. var xs = scheduler.CreateHotObservable(
  265. OnNext(210, 1),
  266. OnNext(240, 2),
  267. OnNext(270, 3),
  268. OnCompleted<int>(300)
  269. );
  270. var ys = scheduler.CreateHotObservable(
  271. OnNext(220, 11),
  272. OnNext(250, 12),
  273. OnNext(280, 13),
  274. OnCompleted<int>(310)
  275. );
  276. var map = new Dictionary<int, IObservable<int>>
  277. {
  278. { 1, xs },
  279. { 2, ys }
  280. };
  281. var results = scheduler.Start(() => Observable.Case(() => 3, map, scheduler));
  282. results.Messages.AssertEqual(
  283. OnCompleted<int>(201)
  284. );
  285. xs.Subscriptions.AssertEqual(
  286. );
  287. ys.Subscriptions.AssertEqual(
  288. );
  289. }
  290. [Fact]
  291. public void CaseWithDefault_Throw()
  292. {
  293. var scheduler = new TestScheduler();
  294. var xs = scheduler.CreateHotObservable(
  295. OnNext(210, 1),
  296. OnNext(240, 2),
  297. OnNext(270, 3),
  298. OnCompleted<int>(300)
  299. );
  300. var ys = scheduler.CreateHotObservable(
  301. OnNext(220, 11),
  302. OnNext(250, 12),
  303. OnNext(280, 13),
  304. OnCompleted<int>(310)
  305. );
  306. var map = new Dictionary<int, IObservable<int>>
  307. {
  308. { 1, xs },
  309. { 2, ys }
  310. };
  311. var ex = new Exception();
  312. var results = scheduler.Start(() => Observable.Case(() => Throw<int>(ex), map, scheduler));
  313. results.Messages.AssertEqual(
  314. OnError<int>(200, ex)
  315. );
  316. xs.Subscriptions.AssertEqual(
  317. );
  318. ys.Subscriptions.AssertEqual(
  319. );
  320. }
  321. [Fact]
  322. public void CaseWithDefault_CheckDefault()
  323. {
  324. Observable.Case(() => 1, new Dictionary<int, IObservable<int>>(), DefaultScheduler.Instance)
  325. .AssertEqual(Observable.Case(() => 1, new Dictionary<int, IObservable<int>>()));
  326. }
  327. [Fact]
  328. public void Case_Error()
  329. {
  330. var scheduler = new TestScheduler();
  331. var ex = new Exception();
  332. var xs = scheduler.CreateHotObservable(
  333. OnNext(210, 1),
  334. OnNext(240, 2),
  335. OnNext(270, 3),
  336. OnError<int>(300, ex)
  337. );
  338. var ys = scheduler.CreateHotObservable(
  339. OnNext(220, 11),
  340. OnNext(250, 12),
  341. OnNext(280, 13),
  342. OnCompleted<int>(310)
  343. );
  344. var map = new Dictionary<int, IObservable<int>>
  345. {
  346. { 1, xs },
  347. { 2, ys }
  348. };
  349. var results = scheduler.Start(() => Observable.Case(() => 1, map, scheduler));
  350. results.Messages.AssertEqual(
  351. OnNext(210, 1),
  352. OnNext(240, 2),
  353. OnNext(270, 3),
  354. OnError<int>(300, ex)
  355. );
  356. xs.Subscriptions.AssertEqual(
  357. Subscribe(200, 300)
  358. );
  359. ys.Subscriptions.AssertEqual(
  360. );
  361. }
  362. private static T Throw<T>(Exception ex)
  363. {
  364. throw ex;
  365. }
  366. }
  367. }