Merge pull request #6 from tektronix/develop

Pull latest fixes from develop into master

Author: dwyban

InitialState.NET/ISStreamer.cs

@@ -238,22 +238,23 @@ public CreateBucketStatus CreateBucket(string accessKey, string bucketKey, strin
             _jsonStrBuilder.Remove(_jsonStrBuilder.Length - 3, 3); // Remove the last ",\r\n"
             _jsonStrBuilder.Append("\r\n]");
 
-            var response = await sendToApi(_jsonStrBuilder.ToString());
-
-            sr.Success = response.StatusCode == System.Net.HttpStatusCode.NoContent;
-            sr.StatusCode = response.StatusCode;
-            int.TryParse(response.Headers.GetValues("X-RateLimit-Limit").First(), out sr.RateLimit);
-            int.TryParse(response.Headers.GetValues("X-RateLimit-Remaining").First(), out sr.RateLimitRemaining);
-            int.TryParse(response.Headers.GetValues("X-RateLimit-Reset").First(), out int epochTimestamp);
-            
-            sr.RateLimitReset = _epochDateTime.AddSeconds(epochTimestamp).ToLocalTime();
-
-            // Data is sent so clear out the buffer
-            if (sr.Success)
+            using (var response = await sendToApi(_jsonStrBuilder.ToString()))
             {
-                this.EventData.Clear();
-            }
 
+                sr.Success = response.StatusCode == System.Net.HttpStatusCode.NoContent;
+                sr.StatusCode = response.StatusCode;
+                int.TryParse(response.Headers.GetValues("X-RateLimit-Limit").First(), out sr.RateLimit);
+                int.TryParse(response.Headers.GetValues("X-RateLimit-Remaining").First(), out sr.RateLimitRemaining);
+                int.TryParse(response.Headers.GetValues("X-RateLimit-Reset").First(), out int epochTimestamp);
+
+                sr.RateLimitReset = _epochDateTime.AddSeconds(epochTimestamp).ToLocalTime();
+
+                // Data is sent so clear out the buffer
+                if (sr.Success)
+                {
+                    this.EventData.Clear();
+                }
+            }
             return sr;
         }
 
@@ -272,9 +273,11 @@ public void Close()
         //----------------
         private async Task<HttpResponseMessage> sendToApi(string jsonData)
         {
-            var response = await _httpClient.PostAsync("events",
-                    new StringContent(jsonData, Encoding.UTF8, "application/json"));
-            return response;
+            using (var content = new StringContent(jsonData, Encoding.UTF8, "application/json"))
+            {
+                var response = await _httpClient.PostAsync("events", content);
+                return response;
+            }
         }
         private void closeHttpClient()
         {

InitialState.NET/Properties/AssemblyInfo.cs

@@ -32,5 +32,5 @@
 // You can specify all the values or you can default the Build and Revision Numbers
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("1.0.0.0")]
-[assembly: AssemblyFileVersion("1.0.0.0")]
+[assembly: AssemblyVersion("1.0.0.1")]
+[assembly: AssemblyFileVersion("1.0.0.1")]

README.md

@@ -8,8 +8,8 @@ The following example shows you basic use of InitialState<nolink/>.NET.  This ex
 
 ```csharp
 ISStreamer stream = new ISStreamer(); // Create a new streamer
-stream.ConnectBucket(api_key, bucket_key); // Connect the streamer to an event data bucket
-stream.Eventsdata.Add(new ISEventData(itemKey, itemValue)) // Add event data to be streamed
+stream.ConnectBucket("api_key", "bucket_key"); // Connect the streamer to an event data bucket
+stream.Eventsdata.Add(new ISEventData("itemKey", "itemValue")) // Add event data to be streamed
 stream.Stream(); // Stream the event data to Initial State
 stream.Close(); // Close the streamer when finished
 ```