Merge pull request #725 from danielcweber/RemoveRedundantInitializers

Remove redundant field initializers.

Rx.NET/Source/src/System.Reactive/Concurrency/AsyncLock.cs

@@ -11,8 +11,8 @@ namespace System.Reactive.Concurrency
     /// </summary>
     public sealed class AsyncLock : IDisposable
     {
-        private bool isAcquired = false;
-        private bool hasFaulted = false;
+        private bool isAcquired;
+        private bool hasFaulted;
         private readonly object guard = new object();
         private Queue<(Action<Delegate, object> action, Delegate @delegate, object state)> queue;
 

Rx.NET/Source/src/System.Reactive/Concurrency/CatchScheduler.cs

@@ -96,7 +96,7 @@ namespace System.Reactive.Concurrency
             private sealed class PeriodicallyScheduledWorkItem<TState> : IDisposable
             {
                 private IDisposable _cancel;
-                private bool _failed = false;
+                private bool _failed;
 
                 private readonly Func<TState, TState> _action;
                 private readonly CatchSchedulerPeriodic _catchScheduler;

Rx.NET/Source/src/System.Reactive/Concurrency/LocalScheduler.TimerQueue.cs

@@ -41,7 +41,7 @@ namespace System.Reactive.Concurrency
         /// or can continue using the current timer (because no earlier long term work was
         /// added to the queue).
         /// </summary>
-        private static WorkItem s_nextLongTermWorkItem = null;
+        private static WorkItem s_nextLongTermWorkItem;
 
         /// <summary>
         /// Short term work queue. Contains work that's due soon, computed at the time of

Rx.NET/Source/src/System.Reactive/Internal/ScheduledObserver.cs

@@ -13,7 +13,7 @@ namespace System.Reactive
 
     internal class ScheduledObserver<T> : ObserverBase<T>, IScheduledObserver<T>
     {
-        private int _state = 0;
+        private int _state;
         private const int STOPPED = 0;
         private const int RUNNING = 1;
         private const int PENDING = 2;

Rx.NET/Source/src/System.Reactive/Linq/Observable/Merge.cs

@@ -40,7 +40,7 @@ namespace System.Reactive.Linq.ObservableImpl
                 private Queue<IObservable<TSource>> _q = new Queue<IObservable<TSource>>();
                 private volatile bool _isStopped;
                 private CompositeDisposable _group = new CompositeDisposable();
-                private int _activeCount = 0;
+                private int _activeCount;
 
                 public override void OnNext(IObservable<TSource> value)
                 {

Rx.NET/Source/src/System.Reactive/Threading/Tasks/TaskObservableExtensions.cs

@@ -309,7 +309,7 @@ namespace System.Reactive.Threading.Tasks
         {
             private readonly CancellationToken _ct;
             private readonly TaskCompletionSource<TResult> _tcs;
-            private readonly CancellationTokenRegistration _ctr = default;
+            private readonly CancellationTokenRegistration _ctr;
 
             private bool _hasValue;
             private TResult _lastValue;