IgnoreElementsTest.cs 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141
  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 Xunit;
  8. namespace ReactiveTests.Tests
  9. {
  10. public class IgnoreElementsTest : ReactiveTest
  11. {
  12. [Fact]
  13. public void IgnoreElements_ArgumentChecking()
  14. {
  15. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.IgnoreElements<int>(null));
  16. }
  17. [Fact]
  18. public void IgnoreElements_IgnoreElements()
  19. {
  20. var scheduler = new TestScheduler();
  21. var xs = scheduler.CreateHotObservable(
  22. OnNext(180, 1),
  23. OnNext(210, 2),
  24. OnNext(250, 3),
  25. OnNext(270, 4),
  26. OnCompleted<int>(300)
  27. );
  28. var res = scheduler.Start(() =>
  29. xs.IgnoreElements().IgnoreElements()
  30. );
  31. res.Messages.AssertEqual(
  32. OnCompleted<int>(300)
  33. );
  34. xs.Subscriptions.AssertEqual(
  35. Subscribe(200, 300)
  36. );
  37. }
  38. [Fact]
  39. public void IgnoreElements_Basic()
  40. {
  41. var scheduler = new TestScheduler();
  42. var xs = scheduler.CreateHotObservable(
  43. OnNext(180, 1),
  44. OnNext(210, 2),
  45. OnNext(250, 3),
  46. OnNext(270, 4),
  47. OnNext(310, 5),
  48. OnNext(360, 6),
  49. OnNext(380, 7),
  50. OnNext(410, 8),
  51. OnNext(590, 9)
  52. );
  53. var res = scheduler.Start(() =>
  54. xs.IgnoreElements()
  55. );
  56. res.Messages.AssertEqual(
  57. );
  58. xs.Subscriptions.AssertEqual(
  59. Subscribe(200, 1000)
  60. );
  61. }
  62. [Fact]
  63. public void IgnoreElements_Completed()
  64. {
  65. var scheduler = new TestScheduler();
  66. var xs = scheduler.CreateHotObservable(
  67. OnNext(180, 1),
  68. OnNext(210, 2),
  69. OnNext(250, 3),
  70. OnNext(270, 4),
  71. OnNext(310, 5),
  72. OnNext(360, 6),
  73. OnNext(380, 7),
  74. OnNext(410, 8),
  75. OnNext(590, 9),
  76. OnCompleted<int>(610)
  77. );
  78. var res = scheduler.Start(() =>
  79. xs.IgnoreElements()
  80. );
  81. res.Messages.AssertEqual(
  82. OnCompleted<int>(610)
  83. );
  84. xs.Subscriptions.AssertEqual(
  85. Subscribe(200, 610)
  86. );
  87. }
  88. [Fact]
  89. public void IgnoreElements_Error()
  90. {
  91. var scheduler = new TestScheduler();
  92. var ex = new Exception();
  93. var xs = scheduler.CreateHotObservable(
  94. OnNext(180, 1),
  95. OnNext(210, 2),
  96. OnNext(250, 3),
  97. OnNext(270, 4),
  98. OnNext(310, 5),
  99. OnNext(360, 6),
  100. OnNext(380, 7),
  101. OnNext(410, 8),
  102. OnNext(590, 9),
  103. OnError<int>(610, ex)
  104. );
  105. var res = scheduler.Start(() =>
  106. xs.IgnoreElements()
  107. );
  108. res.Messages.AssertEqual(
  109. OnError<int>(610, ex)
  110. );
  111. xs.Subscriptions.AssertEqual(
  112. Subscribe(200, 610)
  113. );
  114. }
  115. }
  116. }