TakeLastTest.cs 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914
  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.Reactive.Concurrency;
  8. using System.Reactive.Linq;
  9. using System.Threading;
  10. using Microsoft.Reactive.Testing;
  11. using ReactiveTests.Dummies;
  12. using Xunit;
  13. namespace ReactiveTests.Tests
  14. {
  15. public class TakeLastTest : ReactiveTest
  16. {
  17. #region + Count +
  18. [Fact]
  19. public void TakeLast_ArgumentChecking()
  20. {
  21. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast<int>(null, 0));
  22. ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.TakeLast(DummyObservable<int>.Instance, -1));
  23. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast<int>(null, 0, Scheduler.Default));
  24. ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.TakeLast(DummyObservable<int>.Instance, -1, Scheduler.Default));
  25. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(DummyObservable<int>.Instance, 0, default));
  26. }
  27. [Fact]
  28. public void TakeLast_Zero_Completed()
  29. {
  30. var scheduler = new TestScheduler();
  31. var xs = scheduler.CreateHotObservable(
  32. OnNext(180, 1),
  33. OnNext(210, 2),
  34. OnNext(250, 3),
  35. OnNext(270, 4),
  36. OnNext(310, 5),
  37. OnNext(360, 6),
  38. OnNext(380, 7),
  39. OnNext(410, 8),
  40. OnNext(590, 9),
  41. OnCompleted<int>(650)
  42. );
  43. var res = scheduler.Start(() =>
  44. xs.TakeLast(0)
  45. );
  46. res.Messages.AssertEqual(
  47. OnCompleted<int>(650)
  48. );
  49. xs.Subscriptions.AssertEqual(
  50. Subscribe(200, 650)
  51. );
  52. }
  53. [Fact]
  54. public void TakeLast_Zero_Error()
  55. {
  56. var scheduler = new TestScheduler();
  57. var ex = new Exception();
  58. var xs = scheduler.CreateHotObservable(
  59. OnNext(180, 1),
  60. OnNext(210, 2),
  61. OnNext(250, 3),
  62. OnNext(270, 4),
  63. OnNext(310, 5),
  64. OnNext(360, 6),
  65. OnNext(380, 7),
  66. OnNext(410, 8),
  67. OnNext(590, 9),
  68. OnError<int>(650, ex)
  69. );
  70. var res = scheduler.Start(() =>
  71. xs.TakeLast(0)
  72. );
  73. res.Messages.AssertEqual(
  74. OnError<int>(650, ex)
  75. );
  76. xs.Subscriptions.AssertEqual(
  77. Subscribe(200, 650)
  78. );
  79. }
  80. [Fact]
  81. public void TakeLast_Zero_Disposed()
  82. {
  83. var scheduler = new TestScheduler();
  84. var xs = scheduler.CreateHotObservable(
  85. OnNext(180, 1),
  86. OnNext(210, 2),
  87. OnNext(250, 3),
  88. OnNext(270, 4),
  89. OnNext(310, 5),
  90. OnNext(360, 6),
  91. OnNext(380, 7),
  92. OnNext(410, 8),
  93. OnNext(590, 9)
  94. );
  95. var res = scheduler.Start(() =>
  96. xs.TakeLast(0)
  97. );
  98. res.Messages.AssertEqual(
  99. );
  100. xs.Subscriptions.AssertEqual(
  101. Subscribe(200, 1000)
  102. );
  103. }
  104. [Fact]
  105. public void TakeLast_One_Completed()
  106. {
  107. var scheduler = new TestScheduler();
  108. var xs = scheduler.CreateHotObservable(
  109. OnNext(180, 1),
  110. OnNext(210, 2),
  111. OnNext(250, 3),
  112. OnNext(270, 4),
  113. OnNext(310, 5),
  114. OnNext(360, 6),
  115. OnNext(380, 7),
  116. OnNext(410, 8),
  117. OnNext(590, 9),
  118. OnCompleted<int>(650)
  119. );
  120. var res = scheduler.Start(() =>
  121. xs.TakeLast(1)
  122. );
  123. res.Messages.AssertEqual(
  124. OnNext(650, 9),
  125. OnCompleted<int>(650)
  126. );
  127. xs.Subscriptions.AssertEqual(
  128. Subscribe(200, 650)
  129. );
  130. }
  131. [Fact]
  132. public void TakeLast_One_Error()
  133. {
  134. var scheduler = new TestScheduler();
  135. var ex = new Exception();
  136. var xs = scheduler.CreateHotObservable(
  137. OnNext(180, 1),
  138. OnNext(210, 2),
  139. OnNext(250, 3),
  140. OnNext(270, 4),
  141. OnNext(310, 5),
  142. OnNext(360, 6),
  143. OnNext(380, 7),
  144. OnNext(410, 8),
  145. OnNext(590, 9),
  146. OnError<int>(650, ex)
  147. );
  148. var res = scheduler.Start(() =>
  149. xs.TakeLast(1)
  150. );
  151. res.Messages.AssertEqual(
  152. OnError<int>(650, ex)
  153. );
  154. xs.Subscriptions.AssertEqual(
  155. Subscribe(200, 650)
  156. );
  157. }
  158. [Fact]
  159. public void TakeLast_One_Disposed()
  160. {
  161. var scheduler = new TestScheduler();
  162. var xs = scheduler.CreateHotObservable(
  163. OnNext(180, 1),
  164. OnNext(210, 2),
  165. OnNext(250, 3),
  166. OnNext(270, 4),
  167. OnNext(310, 5),
  168. OnNext(360, 6),
  169. OnNext(380, 7),
  170. OnNext(410, 8),
  171. OnNext(590, 9)
  172. );
  173. var res = scheduler.Start(() =>
  174. xs.TakeLast(1)
  175. );
  176. res.Messages.AssertEqual(
  177. );
  178. xs.Subscriptions.AssertEqual(
  179. Subscribe(200, 1000)
  180. );
  181. }
  182. [Fact]
  183. public void TakeLast_Three_Completed()
  184. {
  185. var scheduler = new TestScheduler();
  186. var xs = scheduler.CreateHotObservable(
  187. OnNext(180, 1),
  188. OnNext(210, 2),
  189. OnNext(250, 3),
  190. OnNext(270, 4),
  191. OnNext(310, 5),
  192. OnNext(360, 6),
  193. OnNext(380, 7),
  194. OnNext(410, 8),
  195. OnNext(590, 9),
  196. OnCompleted<int>(650)
  197. );
  198. var res = scheduler.Start(() =>
  199. xs.TakeLast(3)
  200. );
  201. res.Messages.AssertEqual(
  202. OnNext(650, 7),
  203. OnNext(650, 8),
  204. OnNext(650, 9),
  205. OnCompleted<int>(650)
  206. );
  207. xs.Subscriptions.AssertEqual(
  208. Subscribe(200, 650)
  209. );
  210. }
  211. [Fact]
  212. public void TakeLast_Three_Error()
  213. {
  214. var scheduler = new TestScheduler();
  215. var ex = new Exception();
  216. var xs = scheduler.CreateHotObservable(
  217. OnNext(180, 1),
  218. OnNext(210, 2),
  219. OnNext(250, 3),
  220. OnNext(270, 4),
  221. OnNext(310, 5),
  222. OnNext(360, 6),
  223. OnNext(380, 7),
  224. OnNext(410, 8),
  225. OnNext(590, 9),
  226. OnError<int>(650, ex)
  227. );
  228. var res = scheduler.Start(() =>
  229. xs.TakeLast(3)
  230. );
  231. res.Messages.AssertEqual(
  232. OnError<int>(650, ex)
  233. );
  234. xs.Subscriptions.AssertEqual(
  235. Subscribe(200, 650)
  236. );
  237. }
  238. [Fact]
  239. public void TakeLast_Three_Disposed()
  240. {
  241. var scheduler = new TestScheduler();
  242. var xs = scheduler.CreateHotObservable(
  243. OnNext(180, 1),
  244. OnNext(210, 2),
  245. OnNext(250, 3),
  246. OnNext(270, 4),
  247. OnNext(310, 5),
  248. OnNext(360, 6),
  249. OnNext(380, 7),
  250. OnNext(410, 8),
  251. OnNext(590, 9)
  252. );
  253. var res = scheduler.Start(() =>
  254. xs.TakeLast(3)
  255. );
  256. res.Messages.AssertEqual(
  257. );
  258. xs.Subscriptions.AssertEqual(
  259. Subscribe(200, 1000)
  260. );
  261. }
  262. [Fact]
  263. public void TakeLast_LongRunning_Regular()
  264. {
  265. var res = Observable.Range(0, 100, Scheduler.Default).TakeLast(10, NewThreadScheduler.Default);
  266. var lst = new List<int>();
  267. res.ForEach(lst.Add);
  268. Assert.True(Enumerable.Range(90, 10).SequenceEqual(lst));
  269. }
  270. #endregion
  271. #region + Timed +
  272. [Fact]
  273. public void TakeLast_Timed_ArgumentChecking()
  274. {
  275. var xs = Observable.Return(42);
  276. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(default(IObservable<int>), TimeSpan.FromSeconds(1)));
  277. ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.TakeLast(xs, TimeSpan.FromSeconds(-1)));
  278. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(default(IObservable<int>), TimeSpan.FromSeconds(1), Scheduler.Default));
  279. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(xs, TimeSpan.FromSeconds(1), default));
  280. ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.TakeLast(xs, TimeSpan.FromSeconds(-1), Scheduler.Default));
  281. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(default(IObservable<int>), TimeSpan.FromSeconds(1), Scheduler.Default, Scheduler.Default));
  282. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(xs, TimeSpan.FromSeconds(1), default, Scheduler.Default));
  283. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(xs, TimeSpan.FromSeconds(1), Scheduler.Default, default));
  284. ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.TakeLast(xs, TimeSpan.FromSeconds(-1), Scheduler.Default, Scheduler.Default));
  285. }
  286. [Fact]
  287. public void TakeLast_Zero1()
  288. {
  289. var scheduler = new TestScheduler();
  290. var xs = scheduler.CreateHotObservable(
  291. OnNext(210, 1),
  292. OnNext(220, 2),
  293. OnCompleted<int>(230)
  294. );
  295. var res = scheduler.Start(() =>
  296. xs.TakeLast(TimeSpan.Zero, scheduler)
  297. );
  298. res.Messages.AssertEqual(
  299. OnCompleted<int>(230)
  300. );
  301. xs.Subscriptions.AssertEqual(
  302. Subscribe(200, 230)
  303. );
  304. }
  305. [Fact]
  306. public void TakeLast_Zero1_WithLoopScheduler()
  307. {
  308. var scheduler = new TestScheduler();
  309. var xs = scheduler.CreateHotObservable(
  310. OnNext(210, 1),
  311. OnNext(220, 2),
  312. OnCompleted<int>(230)
  313. );
  314. var res = scheduler.Start(() =>
  315. xs.TakeLast(TimeSpan.Zero, scheduler, scheduler)
  316. );
  317. res.Messages.AssertEqual(
  318. OnCompleted<int>(231)
  319. );
  320. xs.Subscriptions.AssertEqual(
  321. Subscribe(200, 230)
  322. );
  323. }
  324. [Fact]
  325. public void TakeLast_Zero2()
  326. {
  327. var scheduler = new TestScheduler();
  328. var xs = scheduler.CreateHotObservable(
  329. OnNext(210, 1),
  330. OnNext(220, 2),
  331. OnNext(230, 3),
  332. OnCompleted<int>(230)
  333. );
  334. var res = scheduler.Start(() =>
  335. xs.TakeLast(TimeSpan.Zero, scheduler)
  336. );
  337. res.Messages.AssertEqual(
  338. OnCompleted<int>(230)
  339. );
  340. xs.Subscriptions.AssertEqual(
  341. Subscribe(200, 230)
  342. );
  343. }
  344. [Fact]
  345. public void TakeLast_Zero2_WithLoopScheduler()
  346. {
  347. var scheduler = new TestScheduler();
  348. var xs = scheduler.CreateHotObservable(
  349. OnNext(210, 1),
  350. OnNext(220, 2),
  351. OnNext(230, 3),
  352. OnCompleted<int>(230)
  353. );
  354. var res = scheduler.Start(() =>
  355. xs.TakeLast(TimeSpan.Zero, scheduler, scheduler)
  356. );
  357. res.Messages.AssertEqual(
  358. OnCompleted<int>(231)
  359. );
  360. xs.Subscriptions.AssertEqual(
  361. Subscribe(200, 230)
  362. );
  363. }
  364. [Fact]
  365. public void TakeLast_Some1()
  366. {
  367. var scheduler = new TestScheduler();
  368. var xs = scheduler.CreateHotObservable(
  369. OnNext(210, 1),
  370. OnNext(220, 2),
  371. OnNext(230, 3),
  372. OnCompleted<int>(240)
  373. );
  374. var res = scheduler.Start(() =>
  375. xs.TakeLast(TimeSpan.FromTicks(25), scheduler)
  376. );
  377. res.Messages.AssertEqual(
  378. OnNext(240, 2),
  379. OnNext(240, 3),
  380. OnCompleted<int>(240)
  381. );
  382. xs.Subscriptions.AssertEqual(
  383. Subscribe(200, 240)
  384. );
  385. }
  386. [Fact]
  387. public void TakeLast_Some1_WithLoopScheduler()
  388. {
  389. var scheduler = new TestScheduler();
  390. var xs = scheduler.CreateHotObservable(
  391. OnNext(210, 1),
  392. OnNext(220, 2),
  393. OnNext(230, 3),
  394. OnCompleted<int>(240)
  395. );
  396. var res = scheduler.Start(() =>
  397. xs.TakeLast(TimeSpan.FromTicks(25), scheduler, scheduler)
  398. );
  399. res.Messages.AssertEqual(
  400. OnNext(241, 2),
  401. OnNext(242, 3),
  402. OnCompleted<int>(243)
  403. );
  404. xs.Subscriptions.AssertEqual(
  405. Subscribe(200, 240)
  406. );
  407. }
  408. [Fact]
  409. public void TakeLast_Some2()
  410. {
  411. var scheduler = new TestScheduler();
  412. var xs = scheduler.CreateHotObservable(
  413. OnNext(210, 1),
  414. OnNext(220, 2),
  415. OnNext(230, 3),
  416. OnCompleted<int>(300)
  417. );
  418. var res = scheduler.Start(() =>
  419. xs.TakeLast(TimeSpan.FromTicks(25), scheduler)
  420. );
  421. res.Messages.AssertEqual(
  422. OnCompleted<int>(300)
  423. );
  424. xs.Subscriptions.AssertEqual(
  425. Subscribe(200, 300)
  426. );
  427. }
  428. [Fact]
  429. public void TakeLast_Some2_WithLoopScheduler()
  430. {
  431. var scheduler = new TestScheduler();
  432. var xs = scheduler.CreateHotObservable(
  433. OnNext(210, 1),
  434. OnNext(220, 2),
  435. OnNext(230, 3),
  436. OnCompleted<int>(300)
  437. );
  438. var res = scheduler.Start(() =>
  439. xs.TakeLast(TimeSpan.FromTicks(25), scheduler, scheduler)
  440. );
  441. res.Messages.AssertEqual(
  442. OnCompleted<int>(301)
  443. );
  444. xs.Subscriptions.AssertEqual(
  445. Subscribe(200, 300)
  446. );
  447. }
  448. [Fact]
  449. public void TakeLast_Some3()
  450. {
  451. var scheduler = new TestScheduler();
  452. var xs = scheduler.CreateHotObservable(
  453. OnNext(210, 1),
  454. OnNext(220, 2),
  455. OnNext(230, 3),
  456. OnNext(240, 4),
  457. OnNext(250, 5),
  458. OnNext(260, 6),
  459. OnNext(270, 7),
  460. OnNext(280, 8),
  461. OnNext(290, 9),
  462. OnCompleted<int>(300)
  463. );
  464. var res = scheduler.Start(() =>
  465. xs.TakeLast(TimeSpan.FromTicks(45), scheduler)
  466. );
  467. res.Messages.AssertEqual(
  468. OnNext(300, 6),
  469. OnNext(300, 7),
  470. OnNext(300, 8),
  471. OnNext(300, 9),
  472. OnCompleted<int>(300)
  473. );
  474. xs.Subscriptions.AssertEqual(
  475. Subscribe(200, 300)
  476. );
  477. }
  478. [Fact]
  479. public void TakeLast_Some3_WithLoopScheduler()
  480. {
  481. var scheduler = new TestScheduler();
  482. var xs = scheduler.CreateHotObservable(
  483. OnNext(210, 1),
  484. OnNext(220, 2),
  485. OnNext(230, 3),
  486. OnNext(240, 4),
  487. OnNext(250, 5),
  488. OnNext(260, 6),
  489. OnNext(270, 7),
  490. OnNext(280, 8),
  491. OnNext(290, 9),
  492. OnCompleted<int>(300)
  493. );
  494. var res = scheduler.Start(() =>
  495. xs.TakeLast(TimeSpan.FromTicks(45), scheduler, scheduler)
  496. );
  497. res.Messages.AssertEqual(
  498. OnNext(301, 6),
  499. OnNext(302, 7),
  500. OnNext(303, 8),
  501. OnNext(304, 9),
  502. OnCompleted<int>(305)
  503. );
  504. xs.Subscriptions.AssertEqual(
  505. Subscribe(200, 300)
  506. );
  507. }
  508. [Fact]
  509. public void TakeLast_Some4()
  510. {
  511. var scheduler = new TestScheduler();
  512. var xs = scheduler.CreateHotObservable(
  513. OnNext(210, 1),
  514. OnNext(240, 2),
  515. OnNext(250, 3),
  516. OnNext(280, 4),
  517. OnNext(290, 5),
  518. OnNext(300, 6),
  519. OnCompleted<int>(350)
  520. );
  521. var res = scheduler.Start(() =>
  522. xs.TakeLast(TimeSpan.FromTicks(25), scheduler)
  523. );
  524. res.Messages.AssertEqual(
  525. OnCompleted<int>(350)
  526. );
  527. xs.Subscriptions.AssertEqual(
  528. Subscribe(200, 350)
  529. );
  530. }
  531. [Fact]
  532. public void TakeLast_Some4_WithLoopScheduler()
  533. {
  534. var scheduler = new TestScheduler();
  535. var xs = scheduler.CreateHotObservable(
  536. OnNext(210, 1),
  537. OnNext(240, 2),
  538. OnNext(250, 3),
  539. OnNext(280, 4),
  540. OnNext(290, 5),
  541. OnNext(300, 6),
  542. OnCompleted<int>(350)
  543. );
  544. var res = scheduler.Start(() =>
  545. xs.TakeLast(TimeSpan.FromTicks(25), scheduler, scheduler)
  546. );
  547. res.Messages.AssertEqual(
  548. OnCompleted<int>(351)
  549. );
  550. xs.Subscriptions.AssertEqual(
  551. Subscribe(200, 350)
  552. );
  553. }
  554. [Fact]
  555. public void TakeLast_All()
  556. {
  557. var scheduler = new TestScheduler();
  558. var xs = scheduler.CreateHotObservable(
  559. OnNext(210, 1),
  560. OnNext(220, 2),
  561. OnCompleted<int>(230)
  562. );
  563. var res = scheduler.Start(() =>
  564. xs.TakeLast(TimeSpan.FromTicks(50), scheduler)
  565. );
  566. res.Messages.AssertEqual(
  567. OnNext(230, 1),
  568. OnNext(230, 2),
  569. OnCompleted<int>(230)
  570. );
  571. xs.Subscriptions.AssertEqual(
  572. Subscribe(200, 230)
  573. );
  574. }
  575. [Fact]
  576. public void TakeLast_All_WithLoopScheduler()
  577. {
  578. var scheduler = new TestScheduler();
  579. var xs = scheduler.CreateHotObservable(
  580. OnNext(210, 1),
  581. OnNext(220, 2),
  582. OnCompleted<int>(230)
  583. );
  584. var res = scheduler.Start(() =>
  585. xs.TakeLast(TimeSpan.FromTicks(50), scheduler, scheduler)
  586. );
  587. res.Messages.AssertEqual(
  588. OnNext(231, 1),
  589. OnNext(232, 2),
  590. OnCompleted<int>(233)
  591. );
  592. xs.Subscriptions.AssertEqual(
  593. Subscribe(200, 230)
  594. );
  595. }
  596. [Fact]
  597. public void TakeLast_Error()
  598. {
  599. var scheduler = new TestScheduler();
  600. var ex = new Exception();
  601. var xs = scheduler.CreateHotObservable(
  602. OnError<int>(210, ex)
  603. );
  604. var res = scheduler.Start(() =>
  605. xs.TakeLast(TimeSpan.FromTicks(50), scheduler)
  606. );
  607. res.Messages.AssertEqual(
  608. OnError<int>(210, ex)
  609. );
  610. xs.Subscriptions.AssertEqual(
  611. Subscribe(200, 210)
  612. );
  613. }
  614. [Fact]
  615. public void TakeLast_Error_WithLoopScheduler()
  616. {
  617. var scheduler = new TestScheduler();
  618. var ex = new Exception();
  619. var xs = scheduler.CreateHotObservable(
  620. OnError<int>(210, ex)
  621. );
  622. var res = scheduler.Start(() =>
  623. xs.TakeLast(TimeSpan.FromTicks(50), scheduler, scheduler)
  624. );
  625. res.Messages.AssertEqual(
  626. OnError<int>(210, ex)
  627. );
  628. xs.Subscriptions.AssertEqual(
  629. Subscribe(200, 210)
  630. );
  631. }
  632. [Fact]
  633. public void TakeLast_Never()
  634. {
  635. var scheduler = new TestScheduler();
  636. var ex = new Exception();
  637. var xs = scheduler.CreateHotObservable<int>(
  638. );
  639. var res = scheduler.Start(() =>
  640. xs.TakeLast(TimeSpan.FromTicks(50), scheduler)
  641. );
  642. res.Messages.AssertEqual(
  643. );
  644. xs.Subscriptions.AssertEqual(
  645. Subscribe(200, 1000)
  646. );
  647. }
  648. [Fact]
  649. public void TakeLast_Never_WithLoopScheduler()
  650. {
  651. var scheduler = new TestScheduler();
  652. var ex = new Exception();
  653. var xs = scheduler.CreateHotObservable<int>(
  654. );
  655. var res = scheduler.Start(() =>
  656. xs.TakeLast(TimeSpan.FromTicks(50), scheduler, scheduler)
  657. );
  658. res.Messages.AssertEqual(
  659. );
  660. xs.Subscriptions.AssertEqual(
  661. Subscribe(200, 1000)
  662. );
  663. }
  664. [Fact]
  665. public void TakeLast_Default1()
  666. {
  667. var xs = Observable.Range(0, 10, Scheduler.Default);
  668. var res = xs.TakeLast(TimeSpan.FromSeconds(60));
  669. var e = new ManualResetEvent(false);
  670. var lst = new List<int>();
  671. res.Subscribe(
  672. lst.Add,
  673. () => e.Set()
  674. );
  675. e.WaitOne();
  676. Assert.True(lst.SequenceEqual(Enumerable.Range(0, 10)));
  677. }
  678. [Fact]
  679. public void TakeLast_Default2()
  680. {
  681. var xs = Observable.Range(0, 10, Scheduler.Default);
  682. var res = xs.TakeLast(TimeSpan.FromSeconds(60), Scheduler.Default.DisableOptimizations());
  683. var e = new ManualResetEvent(false);
  684. var lst = new List<int>();
  685. res.Subscribe(
  686. lst.Add,
  687. () => e.Set()
  688. );
  689. e.WaitOne();
  690. Assert.True(lst.SequenceEqual(Enumerable.Range(0, 10)));
  691. }
  692. [Fact]
  693. public void TakeLast_Default3()
  694. {
  695. var xs = Observable.Range(0, 10, Scheduler.Default);
  696. var res = xs.TakeLast(TimeSpan.Zero);
  697. var e = new ManualResetEvent(false);
  698. var lst = new List<int>();
  699. res.Subscribe(
  700. lst.Add,
  701. () => e.Set()
  702. );
  703. e.WaitOne();
  704. Assert.True(lst.Count == 0);
  705. }
  706. [Fact]
  707. public void TakeLast_Default4()
  708. {
  709. var xs = Observable.Range(0, 10, Scheduler.Default);
  710. var res = xs.TakeLast(TimeSpan.Zero, Scheduler.Default.DisableOptimizations());
  711. var e = new ManualResetEvent(false);
  712. var lst = new List<int>();
  713. res.Subscribe(
  714. lst.Add,
  715. () => e.Set()
  716. );
  717. e.WaitOne();
  718. Assert.True(lst.Count == 0);
  719. }
  720. [Fact]
  721. public void TakeLast_Timed_LongRunning_Regular()
  722. {
  723. var res = Observable.Range(0, 10, Scheduler.Default).TakeLast(TimeSpan.FromSeconds(60), Scheduler.Default, NewThreadScheduler.Default);
  724. var lst = new List<int>();
  725. res.ForEach(lst.Add);
  726. Assert.True(Enumerable.Range(0, 10).SequenceEqual(lst));
  727. }
  728. #endregion
  729. }
  730. }