Added MessagesQueueCount property to client

src/OpenAPI.Net/OpenAPI.Net.csproj

@@ -9,7 +9,7 @@
     <PackageTags>cTrader, Open API, Spotware</PackageTags>
     <Description>A .NET RX library for Spotware Open API</Description>
     <PackageId>Spotware.OpenAPI.Net</PackageId>
-    <Version>1.3.2</Version>
+    <Version>1.3.3</Version>
     <Platforms>AnyCPU</Platforms>
     <Company>Spotware</Company>
     <Authors>Spotware</Authors>

src/OpenAPI.Net/OpenClient.cs

@@ -108,6 +108,11 @@ public OpenClient(string host, int port, TimeSpan heartbeatInerval, int maxReque
         /// </summary>
         public DateTimeOffset LastSentMessageTime { get; private set; }
 
+        /// <summary>
+        /// The count of messages on queue to be sent
+        /// </summary>
+        public int MessagesQueueCount { get; private set; }
+
         /// <summary>
         /// Connects to the API based on you specified method (websocket or TCP)
         /// </summary>
@@ -235,6 +240,8 @@ public async Task SendMessage<T>(T message, ProtoOAPayloadType payloadType, stri
         /// <returns>Task</returns>
         public async Task SendMessage(ProtoMessage message)
         {
+            MessagesQueueCount += 1;
+
             await _messagesChannel.Writer.WriteAsync(message);
         }
 
@@ -293,6 +300,8 @@ private async Task StartSendingMessages(CancellationToken cancellationToken)
                         }
 
                         await SendMessageInstant(message);
+
+                        if (MessagesQueueCount > 0) MessagesQueueCount -= 1;
                     }
                 }
             }
@@ -321,6 +330,8 @@ public void Dispose()
 
             _messagesChannel.Writer.TryComplete();
 
+            MessagesQueueCount = 0;
+
             if (UseWebSocket)
             {
                 _webSocketMessageReceivedDisposable?.Dispose();