Reformatting/cleanup

Author: bartelink

src/Serilog.Sinks.Async/LoggerConfigurationAsyncExtensions.cs

@@ -16,7 +16,7 @@ public static class LoggerConfigurationAsyncExtensions
         /// <param name="loggerSinkConfiguration">The <see cref="LoggerSinkConfiguration"/> being configured.</param>
         /// <param name="configure">An action that configures the wrapped sink.</param>
         /// <param name="bufferSize">The size of the concurrent queue used to feed the background worker thread. If
-        /// the thread is unable to process events quickly enough and the queue is filled, subsequent events will be 
+        /// the thread is unable to process events quickly enough and the queue is filled, subsequent events will be
         /// dropped until room is made in the queue.</param>
         /// <returns>A <see cref="LoggerConfiguration"/> allowing configuration to continue.</returns>
         [EditorBrowsable(EditorBrowsableState.Never)]
@@ -34,8 +34,8 @@ public static LoggerConfiguration Async(
         /// <param name="loggerSinkConfiguration">The <see cref="LoggerSinkConfiguration"/> being configured.</param>
         /// <param name="configure">An action that configures the wrapped sink.</param>
         /// <param name="bufferSize">The size of the concurrent queue used to feed the background worker thread. If
-        /// the thread is unable to process events quickly enough and the queue is filled, depending on 
-        /// <paramref name="blockWhenFull"/> the queue will block or subsequent events will be dropped until 
+        /// the thread is unable to process events quickly enough and the queue is filled, depending on
+        /// <paramref name="blockWhenFull"/> the queue will block or subsequent events will be dropped until
         /// room is made in the queue.</param>
         /// <param name="blockWhenFull">Block when the queue is full, instead of dropping events.</param>
         /// <returns>A <see cref="LoggerConfiguration"/> allowing configuration to continue.</returns>

src/Serilog.Sinks.Async/Sinks/Async/BackgroundWorkerSink.cs

@@ -1,17 +1,16 @@
 using System;
 using System.Collections.Concurrent;
 using System.Threading;
+using System.Threading.Tasks;
 using Serilog.Core;
 using Serilog.Debugging;
 using Serilog.Events;
-using System.Threading.Tasks;
 
 namespace Serilog.Sinks.Async
 {
     sealed class BackgroundWorkerSink : ILogEventSink, IDisposable
     {
         readonly ILogEventSink _pipeline;
-        readonly int _bufferCapacity;
         readonly bool _blockWhenFull;
         readonly BlockingCollection<LogEvent> _queue;
         readonly Task _worker;
@@ -21,15 +20,14 @@ public BackgroundWorkerSink(ILogEventSink pipeline, int bufferCapacity, bool blo
             if (pipeline == null) throw new ArgumentNullException(nameof(pipeline));
             if (bufferCapacity <= 0) throw new ArgumentOutOfRangeException(nameof(bufferCapacity));
             _pipeline = pipeline;
-            _bufferCapacity = bufferCapacity;
             _blockWhenFull = blockWhenFull;
-            _queue = new BlockingCollection<LogEvent>(_bufferCapacity);
+            _queue = new BlockingCollection<LogEvent>(bufferCapacity);
             _worker = Task.Factory.StartNew(Pump, CancellationToken.None, TaskCreationOptions.LongRunning | TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
         }
 
         public void Emit(LogEvent logEvent)
         {
-            if (this._queue.IsAddingCompleted)
+            if (_queue.IsAddingCompleted)
                 return;
 
             try
@@ -41,12 +39,12 @@ public void Emit(LogEvent logEvent)
                 else
                 {
                     if (!_queue.TryAdd(logEvent))
-                        SelfLog.WriteLine("{0} unable to enqueue, capacity {1}", typeof(BackgroundWorkerSink), _bufferCapacity);
+                        SelfLog.WriteLine("{0} unable to enqueue, capacity {1}", typeof(BackgroundWorkerSink), _queue.BoundedCapacity);
                 }
             }
             catch (InvalidOperationException)
             {
-                // Thrown in the event of a race condition when we try to add another event after 
+                // Thrown in the event of a race condition when we try to add another event after
                 // CompleteAdding has been called
             }
         }