public static class MemoryLeaksTest
{
private static readonly ILiteCollectionAsync<MqttDelivery> _liteCollection;
public static void Run()
{
new TimerService(TimeSpan.FromSeconds(1))
.Start(Write);
new TimerService(TimeSpan.FromSeconds(5))
.Start(Read);
}
private static async Task Read() =>
await _liteCollection
.Query()
.Limit(40)
.ToList();
private static async Task Write() =>
await _liteCollection
.Upsert(new MqttDelivery());
}
public static class MemoryLeaksTest
{
private static readonly ILiteCollectionAsync<MqttDelivery> _liteCollection;
public static void Run()
{
new TimerService(TimeSpan.FromSeconds(1))
.Start(Write);
new TimerService(TimeSpan.FromSeconds(5))
.Start(Read);
}
private static async Task Read() =>
await _liteCollection
.Query()
.Limit(40)
.ToList();
private static async Task Write() =>
await _liteCollection
.Upsert(new MqttDelivery());
}