We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ed485ac commit 27db86bCopy full SHA for 27db86b
src/dds.net-connector-csharp.lib/Interfaces/SyncQueue/SyncQueueValuetype.cs
@@ -20,6 +20,8 @@ internal class SyncQueueValuetype<T>
20
private int _nextWriteIndex;
21
private int _nextReadIndex;
22
23
+ public event Action? DataAvailable;
24
+
25
/// <summary>
26
/// Initializes queue with specified size.
27
/// </summary>
@@ -93,6 +95,8 @@ public void Enqueue(T data)
93
95
if (_nextWriteIndex == _queue.Length)
94
96
_nextWriteIndex = 0;
97
}
98
99
+ DataAvailable?.Invoke();
100
101
102
public void Dispose()
0 commit comments