firing event when data is enqueued

usa-m · usa-m · commit ed485ac6a8e6 · 2023-03-24T09:13:24.000+05:00
diff --git a/src/dds.net-connector-csharp.lib/Interfaces/SyncQueue/SyncQueue.cs b/src/dds.net-connector-csharp.lib/Interfaces/SyncQueue/SyncQueue.cs
@@ -19,6 +19,8 @@ internal class SyncQueue<T>
         private int _nextWriteIndex;
         private int _nextReadIndex;
 
+        public event Action? DataAvailable;
+
         /// <summary>
         /// Initializes queue with specified size.
         /// </summary>
@@ -113,6 +115,8 @@ public void Enqueue(T data)
 
                 Thread.Sleep(SLEEP_TIME_MS_WHEN_DATA_CANNOT_BE_ENQUEUED);
             }
+
+            DataAvailable?.Invoke();
         }
 
         public void Clear()

Original file line number	Diff line number	Diff line change
`@@ -19,6 +19,8 @@ internal class SyncQueue<T>`
`19`	`19`	`private int _nextWriteIndex;`
`20`	`20`	`private int _nextReadIndex;`
`21`	`21`
	`22`	`+ public event Action? DataAvailable;`
	`23`	`+`
`22`	`24`	`/// <summary>`
`23`	`25`	`/// Initializes queue with specified size.`
`24`	`26`	`/// </summary>`
`@@ -113,6 +115,8 @@ public void Enqueue(T data)`
`113`	`115`
`114`	`116`	`Thread.Sleep(SLEEP_TIME_MS_WHEN_DATA_CANNOT_BE_ENQUEUED);`
`115`	`117`	`}`
	`118`	`+`
	`119`	`+ DataAvailable?.Invoke();`
`116`	`120`	`}`
`117`	`121`
`118`	`122`	`public void Clear()`