Change accesibility of some internal methods/fields to private.

Rx.NET/Source/src/System.Reactive/Concurrency/Scheduler.Recursive.cs

@@ -201,7 +201,7 @@ namespace System.Reactive.Concurrency
                 _recurseCallback = state => InvokeNext(state);
             }
 
-            internal void InvokeNext(TState state)
+            private void InvokeNext(TState state)
             {
                 var sad = new SingleAssignmentDisposable();
 
@@ -230,7 +230,7 @@ namespace System.Reactive.Concurrency
                 _recurseCallback = (state, time) => InvokeNext(state, time);
             }
 
-            internal void InvokeNext(TState state, TimeSpan time)
+            private void InvokeNext(TState state, TimeSpan time)
             {
                 var sad = new SingleAssignmentDisposable();
 
@@ -258,7 +258,7 @@ namespace System.Reactive.Concurrency
                 _recurseCallback = (state, dtOffset) => InvokeNext(state, dtOffset);
             }
 
-            internal void InvokeNext(TState state, DateTimeOffset dtOffset)
+            private void InvokeNext(TState state, DateTimeOffset dtOffset)
             {
                 var sad = new SingleAssignmentDisposable();
 

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

@@ -307,9 +307,9 @@ namespace System.Reactive.Linq.ObservableImpl
 
         private sealed class Node<T>
         {
-            public readonly Node<T> Parent;
-            public readonly T Value;
-            public readonly int Count;
+            private readonly Node<T> _parent;
+            private readonly T _value;
+            private readonly int _count;
 
             public Node(T value)
                 : this(null, value)
@@ -318,44 +318,44 @@ namespace System.Reactive.Linq.ObservableImpl
 
             public Node(Node<T> parent, T value)
             {
-                Parent = parent;
-                Value = value;
+                _parent = parent;
+                _value = value;
 
                 if (parent == null)
                 {
-                    Count = 1;
+                    _count = 1;
                 }
                 else
                 {
-                    if (parent.Count == int.MaxValue)
+                    if (parent._count == int.MaxValue)
                     {
                         throw new NotSupportedException($"Consecutive appends or prepends with a count of more than int.MaxValue ({int.MaxValue}) are not supported.");
                     }
 
-                    Count = parent.Count + 1;
+                    _count = parent._count + 1;
                 }
             }
 
             public T[] ToArray()
             {
-                var array = new T[Count];
+                var array = new T[_count];
                 var current = this;
-                for (var i = 0; i < Count; i++)
+                for (var i = 0; i < _count; i++)
                 {
-                    array[i] = current.Value;
-                    current = current.Parent;
+                    array[i] = current._value;
+                    current = current._parent;
                 }
                 return array;
             }
 
             public T[] ToReverseArray()
             {
-                var array = new T[Count];
+                var array = new T[_count];
                 var current = this;
-                for (var i = Count - 1; i >= 0; i--)
+                for (var i = _count - 1; i >= 0; i--)
                 {
-                    array[i] = current.Value;
-                    current = current.Parent;
+                    array[i] = current._value;
+                    current = current._parent;
                 }
                 return array;
             }

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

@@ -102,12 +102,12 @@ namespace System.Reactive.Linq.ObservableImpl
                 HalfSerializer.ForwardOnNext(this, value, ref _halfSerializer, ref _error);
             }
 
-            internal void HandlerError(Exception error)
+            private void HandlerError(Exception error)
             {
                 HalfSerializer.ForwardOnError(this, error, ref _halfSerializer, ref _error);
             }
 
-            internal void HandlerComplete()
+            private void HandlerComplete()
             {
                 HalfSerializer.ForwardOnCompleted(this, ref _halfSerializer, ref _error);
             }

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

@@ -101,12 +101,12 @@ namespace System.Reactive.Linq.ObservableImpl
                 HalfSerializer.ForwardOnNext(this, value, ref _halfSerializer, ref _error);
             }
 
-            internal void HandlerError(Exception error)
+            private void HandlerError(Exception error)
             {
                 HalfSerializer.ForwardOnError(this, error, ref _halfSerializer, ref _error);
             }
 
-            internal void HandlerComplete()
+            private void HandlerComplete()
             {
                 HalfSerializer.ForwardOnCompleted(this, ref _halfSerializer, ref _error);
             }