First step to enable nullable in Rx.
@@ -2,6 +2,8 @@
// The .NET Foundation licenses this file to you under the MIT License.
// See the LICENSE file in the project root for more information.
+#nullable disable
+
using System.Reactive.Disposables;
namespace System.Reactive
{
/// <summary>
using System.Threading;
using System.Collections.Generic;
namespace System.Reactive.Concurrency
using System.Runtime.CompilerServices;
using System.ComponentModel;
using System.Reactive.PlatformServices;
#if NO_THREAD && WINDOWS
#if !NO_THREAD
using System.Linq;
using System.Diagnostics;
/*
using System.Threading.Tasks;
//
public static partial class Scheduler
using System.Globalization;
internal static class SchedulerDefaults
internal sealed class Synchronize<TSource> : Producer<TSource, Synchronize<TSource>._>
#if NO_THREAD
#if LEGACY_WINRT
using Windows.System.Threading;
#if !LEGACY_WINRT && !NO_THREAD
namespace System.Reactive.Disposables
using System.Collections;
using System.Reactive.Concurrency;
namespace System.Reactive.PlatformServices
internal sealed class EventPatternSource<TEventArgs> : EventPatternSourceBase<object, TEventArgs>, IEventPatternSource<TEventArgs>
#if NO_CODE_COVERAGE_ATTRIBUTE
namespace System.Diagnostics.CodeAnalysis
// This file is used by Code Analysis to maintain SuppressMessage
// attributes that are applied to this project.
// Project-level suppressions either have no target or are given
internal sealed class BinaryObserver<TLeft, TRight> : IObserver<Either<Notification<TLeft>, Notification<TRight>>>
// We can't make those based on the Strings_Core.resx file, because the ObsoleteAttribute needs a compile-time constant.
// WARNING: The full namespace-qualified type name should stay the same for the discovery in System.Reactive.Core to work!
using System.Runtime.ExceptionServices;
#if WINDOWS
using Windows.ApplicationModel;
using Windows.ApplicationModel.Core;
internal interface IEvaluatableObservable<out T>
internal abstract class IdentitySink<T> : Sink<T, T>
internal sealed class ImmutableList<T>
internal sealed class NopObserver<T> : IObserver<T>
#if NO_PERF