diff --git a/Reactive/ReactiveStream.cs b/Reactive/ReactiveStream.cs index fa9b2b2..feec05a 100644 --- a/Reactive/ReactiveStream.cs +++ b/Reactive/ReactiveStream.cs @@ -7,7 +7,7 @@ using System.Threading.Tasks; namespace DTLib.Reactive { - public class ReactiveStream + public class ReactiveStream { List Storage = new(); public event EventHandlerAsync ElementAdded; @@ -23,7 +23,7 @@ namespace DTLib.Reactive if (StoreData) StorageAccess.Execute(() => Storage.Add(elem)); ElementAdded?.Invoke(this, elem); } - + public void Clear() { if (StoreData) StorageAccess.Execute(() => Storage.Clear());