allow custom handling of connection status types through a delegate settable on ConnectionSettings

Author: ahardy

src/Nest/Domain/Connection/Connection.cs

@@ -1,11 +1,11 @@
 using System;
+using System.Collections.Generic;
 using System.Collections.Specialized;
-using System.Text;
+using System.IO;
 using System.Net;
+using System.Text;
 using System.Threading;
-using System.IO;
 using System.Threading.Tasks;
-using System.Collections.Generic;
 
 namespace Nest
 {
@@ -185,6 +185,9 @@ protected virtual ConnectionStatus DoSynchronousRequest(HttpWebRequest request,
 						RequestUrl = request.RequestUri.ToString(),
 						RequestMethod = request.Method
 					};
+
+                    _ConnectionSettings.ConnectionStatusHandler(cs);
+
 					return cs;
 				}
 			}
@@ -210,6 +213,7 @@ protected virtual Task<ConnectionStatus> DoAsyncRequest(HttpWebRequest request,
 				return Task.Factory.StartNew(() =>
 				{
 					this.Iterate(this._AsyncSteps(request, tcs, data), tcs);
+                    _ConnectionSettings.ConnectionStatusHandler(tcs.Task.Result);
 					return tcs.Task.Result;
 				}, TaskCreationOptions.LongRunning);
 			}

src/Nest/Domain/Connection/ConnectionSettings.cs

@@ -29,6 +29,7 @@ public string DefaultIndex
         public bool UsesPrettyResponses { get; private set; }
 
         public Func<Type, string> DefaultTypeNameInferrer { get; private set; }
+        public Action<ConnectionStatus> ConnectionStatusHandler { get; private set; }
         public FluentDictionary<Type, string> DefaultIndices { get; private set; }
         public FluentDictionary<Type, string> DefaultTypeNames { get; private set; }
         public NameValueCollection QueryStringParameters { get; private set; }
@@ -49,6 +50,7 @@ public ConnectionSettings(Uri uri, NameValueCollection queryStringParamaters)
             this.DefaultTypeNameInferrer = this.LowerCaseAndPluralizeTypeNameInferrer;
             this.DefaultIndices = new FluentDictionary<Type, string>();
             this.DefaultTypeNames = new FluentDictionary<Type, string>();
+            this.ConnectionStatusHandler = this.ConnectionStatusDefaultHandler;
             this.QueryStringParameters = queryStringParamaters;
         }
 
@@ -119,13 +121,25 @@ private string LowerCaseAndPluralizeTypeNameInferrer(Type type)
             return Inflector.MakePlural(type.Name).ToLower();
         }
 
+        private void ConnectionStatusDefaultHandler(ConnectionStatus status)
+        {
+            return;
+        }
+
         public ConnectionSettings SetDefaultTypeNameInferrer(Func<Type, string> defaultTypeNameInferrer)
         {
             defaultTypeNameInferrer.ThrowIfNull("defaultTypeNameInferrer");
             this.DefaultTypeNameInferrer = defaultTypeNameInferrer;
             return this;
         }
 
+        public ConnectionSettings SetConnectionStatusHandler(Action<ConnectionStatus> handler)
+        {
+            handler.ThrowIfNull("handler");
+            this.ConnectionStatusHandler = handler;
+            return this;
+        }
+
         public ConnectionSettings MapDefaultTypeIndices(Action<FluentDictionary<Type, string>> mappingSelector)
         {
             mappingSelector.ThrowIfNull("mappingSelector");

src/Nest/Domain/Connection/IConnectionSettings.cs

@@ -21,6 +21,7 @@ public interface IConnectionSettings
         Uri Uri { get; }
 
         NameValueCollection QueryStringParameters { get; }
+        Action<ConnectionStatus> ConnectionStatusHandler { get; }
 
         Func<Type, string> DefaultTypeNameInferrer { get; }
     }