DefaultIfEmptyTest.cs 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170
  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.Linq;
  6. using System.Reactive.Linq;
  7. using Microsoft.Reactive.Testing;
  8. using Xunit;
  9. namespace ReactiveTests.Tests
  10. {
  11. public class DefaultIfEmptyTest : ReactiveTest
  12. {
  13. [Fact]
  14. public void DefaultIfEmpty_ArgumentChecking()
  15. {
  16. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.DefaultIfEmpty(default(IObservable<int>)));
  17. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.DefaultIfEmpty(default, 42));
  18. }
  19. [Fact]
  20. public void DefaultIfEmpty_NonEmpty1()
  21. {
  22. var scheduler = new TestScheduler();
  23. var xs = scheduler.CreateHotObservable(
  24. OnNext(280, 42),
  25. OnNext(360, 43),
  26. OnCompleted<int>(420)
  27. );
  28. var res = scheduler.Start(() =>
  29. xs.DefaultIfEmpty()
  30. );
  31. res.Messages.AssertEqual(
  32. OnNext(280, 42),
  33. OnNext(360, 43),
  34. OnCompleted<int>(420)
  35. );
  36. xs.Subscriptions.AssertEqual(
  37. Subscribe(200, 420)
  38. );
  39. }
  40. [Fact]
  41. public void DefaultIfEmpty_NonEmpty2()
  42. {
  43. var scheduler = new TestScheduler();
  44. var xs = scheduler.CreateHotObservable(
  45. OnNext(280, 42),
  46. OnNext(360, 43),
  47. OnCompleted<int>(420)
  48. );
  49. var res = scheduler.Start(() =>
  50. xs.DefaultIfEmpty(-1)
  51. );
  52. res.Messages.AssertEqual(
  53. OnNext(280, 42),
  54. OnNext(360, 43),
  55. OnCompleted<int>(420)
  56. );
  57. xs.Subscriptions.AssertEqual(
  58. Subscribe(200, 420)
  59. );
  60. }
  61. [Fact]
  62. public void DefaultIfEmpty_Empty1()
  63. {
  64. var scheduler = new TestScheduler();
  65. var xs = scheduler.CreateHotObservable(
  66. OnCompleted<int>(420)
  67. );
  68. var res = scheduler.Start(() =>
  69. xs.DefaultIfEmpty()
  70. );
  71. res.Messages.AssertEqual(
  72. OnNext(420, 0),
  73. OnCompleted<int>(420)
  74. );
  75. xs.Subscriptions.AssertEqual(
  76. Subscribe(200, 420)
  77. );
  78. }
  79. [Fact]
  80. public void DefaultIfEmpty_Empty2()
  81. {
  82. var scheduler = new TestScheduler();
  83. var xs = scheduler.CreateHotObservable(
  84. OnCompleted<int>(420)
  85. );
  86. var res = scheduler.Start(() =>
  87. xs.DefaultIfEmpty(-1)
  88. );
  89. res.Messages.AssertEqual(
  90. OnNext(420, -1),
  91. OnCompleted<int>(420)
  92. );
  93. xs.Subscriptions.AssertEqual(
  94. Subscribe(200, 420)
  95. );
  96. }
  97. [Fact]
  98. public void DefaultIfEmpty_Throw1()
  99. {
  100. var ex = new Exception();
  101. var scheduler = new TestScheduler();
  102. var xs = scheduler.CreateHotObservable(
  103. OnError<int>(420, ex)
  104. );
  105. var res = scheduler.Start(() =>
  106. xs.DefaultIfEmpty()
  107. );
  108. res.Messages.AssertEqual(
  109. OnError<int>(420, ex)
  110. );
  111. xs.Subscriptions.AssertEqual(
  112. Subscribe(200, 420)
  113. );
  114. }
  115. [Fact]
  116. public void DefaultIfEmpty_Throw2()
  117. {
  118. var ex = new Exception();
  119. var scheduler = new TestScheduler();
  120. var xs = scheduler.CreateHotObservable(
  121. OnError<int>(420, ex)
  122. );
  123. var res = scheduler.Start(() =>
  124. xs.DefaultIfEmpty(42)
  125. );
  126. res.Messages.AssertEqual(
  127. OnError<int>(420, ex)
  128. );
  129. xs.Subscriptions.AssertEqual(
  130. Subscribe(200, 420)
  131. );
  132. }
  133. }
  134. }