26 lines
725 B
C#
26 lines
725 B
C#
using System;
|
|
using System.Collections.Generic;
|
|
|
|
namespace DTLib.Reactive
|
|
{
|
|
public class ReactiveStream<T>
|
|
{
|
|
List<(long time, T value)> Storage = new();
|
|
public event EventHandlerAsync<T> ElementAdded;
|
|
SafeMutex StorageMutex = new();
|
|
public int Length => StorageMutex.Execute(() => Storage.Count);
|
|
|
|
public ReactiveStream() { }
|
|
|
|
public void Add(T elem)
|
|
{
|
|
StorageMutex.Execute(() => Storage.Add((DateTime.Now.Ticks, elem)));
|
|
ElementAdded?.Invoke(this, elem);
|
|
}
|
|
|
|
public void Get(int index) => StorageMutex.Execute(() => Storage[index]);
|
|
|
|
public void Clear() => StorageMutex.Execute(() => Storage.Clear());
|
|
}
|
|
}
|