diff --git a/Notifications/StreamingSubscriptionConnection.cs b/Notifications/StreamingSubscriptionConnection.cs
index fdef52fb..da84e95e 100644
--- a/Notifications/StreamingSubscriptionConnection.cs
+++ b/Notifications/StreamingSubscriptionConnection.cs
@@ -58,6 +58,11 @@ public sealed class StreamingSubscriptionConnection : IDisposable
         /// </summary>
         private GetStreamingEventsRequest currentHangingRequest;
         
+        /// <summary>
+        /// Whether OnConnectionCompleted has been fired since last connect
+        /// </summary>
+        private bool hasFiredConnectionCompleted;
+
         /// <summary>
         /// Lock object
         /// </summary>
@@ -87,6 +92,11 @@ public sealed class StreamingSubscriptionConnection : IDisposable
         /// </summary>
         public event SubscriptionErrorDelegate OnSubscriptionError;
 
+        /// <summary>
+        /// Occurs on the first response from the server, successfull or not.
+        /// </summary>
+        public event EventHandler OnConnectionCompleted;
+
         /// <summary>
         /// Occurs when a streaming subscription connection is disconnected from the server.
         /// </summary>
@@ -215,6 +225,8 @@ public void Open()
                     throw new ServiceLocalException(Strings.NoSubscriptionsOnConnection);
                 }
 
+                this.hasFiredConnectionCompleted = false;
+
                 this.currentHangingRequest = new GetStreamingEventsRequest(
                     this.session,
                     this.HandleServiceResponseObject,
@@ -317,6 +329,13 @@ private void HandleServiceResponseObject(object response)
             }
             else
             {
+                if (!hasFiredConnectionCompleted)
+                {
+                    EventHandler onConnectionCompleted = OnConnectionCompleted;
+                    if (onConnectionCompleted != null)
+                      onConnectionCompleted(this, new EventArgs());
+                    hasFiredConnectionCompleted = true;
+                }
                 if (gseResponse.Result == ServiceResult.Success || gseResponse.Result == ServiceResult.Warning)
                 {
                     if (gseResponse.Results.Notifications.Count > 0)