|
@@ -865,7 +865,7 @@ namespace ReactiveTests.Tests
|
|
|
{
|
|
|
ReactiveAssert.Throws<ArgumentNullException>(() => Qbservable.ObserveOn(_qbMy, default(IScheduler)));
|
|
|
ReactiveAssert.Throws<ArgumentNullException>(() => Qbservable.ObserveOn(_qbMy, default(SynchronizationContext)));
|
|
|
-#if !NO_DISPATCHER
|
|
|
+#if HAS_DISPATCHER
|
|
|
ReactiveAssert.Throws<ArgumentNullException>(() => Qbservable.ObserveOn(_qbMy, default(DispatcherScheduler)));
|
|
|
#endif
|
|
|
#if HAS_WINFORMS
|
|
@@ -874,12 +874,12 @@ namespace ReactiveTests.Tests
|
|
|
#endif
|
|
|
ReactiveAssert.Throws<ArgumentNullException>(() => Qbservable.ObserveOn(_qbNull, Scheduler.Immediate));
|
|
|
ReactiveAssert.Throws<ArgumentNullException>(() => Qbservable.ObserveOn(_qbNull, new SynchronizationContext()));
|
|
|
-#if !NO_DISPATCHER
|
|
|
+#if HAS_DISPATCHER
|
|
|
ReactiveAssert.Throws<ArgumentNullException>(() => Qbservable.ObserveOn(_qbNull, DispatcherScheduler.Instance));
|
|
|
#endif
|
|
|
}
|
|
|
|
|
|
-#if !NO_DISPATCHER
|
|
|
+#if HAS_DISPATCHER
|
|
|
[Fact]
|
|
|
public void ObserveOn()
|
|
|
{
|
|
@@ -1152,12 +1152,12 @@ namespace ReactiveTests.Tests
|
|
|
{
|
|
|
ReactiveAssert.Throws<ArgumentNullException>(() => Qbservable.SubscribeOn(_qbMy, default(IScheduler)));
|
|
|
ReactiveAssert.Throws<ArgumentNullException>(() => Qbservable.SubscribeOn(_qbMy, default(SynchronizationContext)));
|
|
|
-#if !NO_DISPATCHER
|
|
|
+#if HAS_DISPATCHER
|
|
|
ReactiveAssert.Throws<ArgumentNullException>(() => Qbservable.SubscribeOn(_qbMy, default(DispatcherScheduler)));
|
|
|
#endif
|
|
|
ReactiveAssert.Throws<ArgumentNullException>(() => Qbservable.SubscribeOn(_qbNull, Scheduler.Immediate));
|
|
|
ReactiveAssert.Throws<ArgumentNullException>(() => Qbservable.SubscribeOn(_qbNull, new SynchronizationContext()));
|
|
|
-#if !NO_DISPATCHER
|
|
|
+#if HAS_DISPATCHER
|
|
|
ReactiveAssert.Throws<ArgumentNullException>(() => Qbservable.SubscribeOn(_qbNull, DispatcherScheduler.Instance));
|
|
|
#endif
|
|
|
#if HAS_WINFORMS
|
|
@@ -1171,7 +1171,7 @@ namespace ReactiveTests.Tests
|
|
|
{
|
|
|
_qbMy.SubscribeOn(Scheduler.Immediate);
|
|
|
_qbMy.SubscribeOn(new SynchronizationContext());
|
|
|
-#if !NO_DISPATCHER
|
|
|
+#if HAS_DISPATCHER
|
|
|
Qbservable.SubscribeOn(_qbMy, DispatcherScheduler.Instance);
|
|
|
#endif
|
|
|
#if HAS_WINFORMS
|