AsObservableTest.cs 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176
  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 AsObservableTest : ReactiveTest
  11. {
  12. [Fact]
  13. public void AsObservable_ArgumentChecking()
  14. {
  15. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.AsObservable<int>(null));
  16. }
  17. [Fact]
  18. public void AsObservable_AsObservable()
  19. {
  20. var scheduler = new TestScheduler();
  21. var xs = scheduler.CreateHotObservable(
  22. OnNext(150, 1),
  23. OnNext(220, 2),
  24. OnCompleted<int>(250)
  25. );
  26. var ys = xs.AsObservable().AsObservable();
  27. Assert.NotSame(xs, ys);
  28. var res = scheduler.Start(() =>
  29. ys
  30. );
  31. res.Messages.AssertEqual(
  32. OnNext(220, 2),
  33. OnCompleted<int>(250)
  34. );
  35. xs.Subscriptions.AssertEqual(
  36. Subscribe(200, 250)
  37. );
  38. }
  39. [Fact]
  40. public void AsObservable_Hides()
  41. {
  42. var xs = Observable.Empty<int>();
  43. var res = xs.AsObservable();
  44. Assert.NotSame(xs, res);
  45. }
  46. [Fact]
  47. public void AsObservable_Never()
  48. {
  49. var scheduler = new TestScheduler();
  50. var xs = Observable.Never<int>();
  51. var res = scheduler.Start(() =>
  52. xs.AsObservable()
  53. );
  54. res.Messages.AssertEqual(
  55. );
  56. }
  57. [Fact]
  58. public void AsObservable_Empty()
  59. {
  60. var scheduler = new TestScheduler();
  61. var xs = scheduler.CreateHotObservable(
  62. OnNext(150, 1),
  63. OnCompleted<int>(250)
  64. );
  65. var res = scheduler.Start(() =>
  66. xs.AsObservable()
  67. );
  68. res.Messages.AssertEqual(
  69. OnCompleted<int>(250)
  70. );
  71. xs.Subscriptions.AssertEqual(
  72. Subscribe(200, 250)
  73. );
  74. }
  75. [Fact]
  76. public void AsObservable_Throw()
  77. {
  78. var scheduler = new TestScheduler();
  79. var ex = new Exception();
  80. var xs = scheduler.CreateHotObservable(
  81. OnNext(150, 1),
  82. OnError<int>(250, ex)
  83. );
  84. var res = scheduler.Start(() =>
  85. xs.AsObservable()
  86. );
  87. res.Messages.AssertEqual(
  88. OnError<int>(250, ex)
  89. );
  90. xs.Subscriptions.AssertEqual(
  91. Subscribe(200, 250)
  92. );
  93. }
  94. [Fact]
  95. public void AsObservable_Return()
  96. {
  97. var scheduler = new TestScheduler();
  98. var xs = scheduler.CreateHotObservable(
  99. OnNext(150, 1),
  100. OnNext(220, 2),
  101. OnCompleted<int>(250)
  102. );
  103. var res = scheduler.Start(() =>
  104. xs.AsObservable()
  105. );
  106. res.Messages.AssertEqual(
  107. OnNext(220, 2),
  108. OnCompleted<int>(250)
  109. );
  110. xs.Subscriptions.AssertEqual(
  111. Subscribe(200, 250)
  112. );
  113. }
  114. [Fact]
  115. public void AsObservable_IsNotEager()
  116. {
  117. var scheduler = new TestScheduler();
  118. var subscribed = false;
  119. var xs = Observable.Create<int>(obs =>
  120. {
  121. subscribed = true;
  122. var disp = scheduler.CreateHotObservable(
  123. OnNext(150, 1),
  124. OnNext(220, 2),
  125. OnCompleted<int>(250)
  126. ).Subscribe(obs);
  127. return disp.Dispose;
  128. });
  129. xs.AsObservable();
  130. Assert.False(subscribed);
  131. var res = scheduler.Start(() =>
  132. xs.AsObservable()
  133. );
  134. Assert.True(subscribed);
  135. }
  136. }
  137. }