ThrowTest.cs 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
  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.Concurrency;
  6. using System.Reactive.Linq;
  7. using System.Threading;
  8. using Microsoft.Reactive.Testing;
  9. using ReactiveTests.Dummies;
  10. using Xunit;
  11. namespace ReactiveTests.Tests
  12. {
  13. public class ThrowTest : ReactiveTest
  14. {
  15. [Fact]
  16. public void Throw_ArgumentChecking()
  17. {
  18. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Throw<int>(null));
  19. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Throw(null, 42));
  20. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Throw<int>(new Exception(), null));
  21. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Throw(new Exception(), null, 42));
  22. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Throw<int>(null, DummyScheduler.Instance));
  23. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Throw(null, DummyScheduler.Instance, 42));
  24. ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Throw<int>(new Exception(), DummyScheduler.Instance).Subscribe(null));
  25. }
  26. [Fact]
  27. public void Throw_Basic()
  28. {
  29. var scheduler = new TestScheduler();
  30. var ex = new Exception();
  31. var res = scheduler.Start(() =>
  32. Observable.Throw<int>(ex, scheduler)
  33. );
  34. res.Messages.AssertEqual(
  35. OnError<int>(201, ex)
  36. );
  37. }
  38. [Fact]
  39. public void Throw_Disposed()
  40. {
  41. var scheduler = new TestScheduler();
  42. var res = scheduler.Start(() =>
  43. Observable.Throw<int>(new Exception(), scheduler),
  44. 200
  45. );
  46. res.Messages.AssertEqual(
  47. );
  48. }
  49. [Fact]
  50. public void Throw_ObserverThrows()
  51. {
  52. var scheduler1 = new TestScheduler();
  53. var xs = Observable.Throw<int>(new Exception(), scheduler1);
  54. xs.Subscribe(x => { }, ex => { throw new InvalidOperationException(); }, () => { });
  55. ReactiveAssert.Throws<InvalidOperationException>(() => scheduler1.Start());
  56. }
  57. [Fact]
  58. public void Throw_DefaultScheduler()
  59. {
  60. var ex = new Exception();
  61. Observable.Throw<int>(ex).AssertEqual(Observable.Throw<int>(ex, DefaultScheduler.Instance));
  62. }
  63. [Fact]
  64. public void Throw_Witness_Basic1()
  65. {
  66. var scheduler = new TestScheduler();
  67. var ex = new Exception();
  68. var res = scheduler.Start(() =>
  69. Observable.Throw(ex, scheduler, 42)
  70. );
  71. res.Messages.AssertEqual(
  72. OnError<int>(201, ex)
  73. );
  74. }
  75. [Fact]
  76. public void Throw_Witness_Basic2()
  77. {
  78. var e = new ManualResetEvent(false);
  79. var ex = new Exception();
  80. var res = default(Exception);
  81. Observable.Throw(ex, 42).Subscribe(
  82. _ => { Assert.True(false); },
  83. err => { res = err; e.Set(); },
  84. () => { Assert.True(false); }
  85. );
  86. e.WaitOne();
  87. Assert.Same(ex, res);
  88. }
  89. }
  90. }