< Summary

Information
Class: Elsa.Diagnostics.StructuredLogs.Persistence.Relational.Services.StructuredLogWriteBufferBackgroundTask
Assembly: Elsa.Diagnostics.StructuredLogs.Persistence.Relational
File(s): /home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Diagnostics.StructuredLogs.Persistence.Relational/Services/StructuredLogWriteBufferBackgroundTask.cs
Line coverage
0%
Covered lines: 0
Uncovered lines: 12
Coverable lines: 12
Total lines: 31
Line coverage: 0%
Branch coverage
0%
Covered branches: 0
Total branches: 4
Branch coverage: 0%
Method coverage

Feature is only available for sponsors

Upgrade to PRO version

Metrics

MethodBranch coverage Crap Score Cyclomatic complexity Line coverage
.ctor(...)100%210%
StartAsync()0%620%
ExecuteAsync(...)100%210%
StopAsync()0%620%

File(s)

/home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Diagnostics.StructuredLogs.Persistence.Relational/Services/StructuredLogWriteBufferBackgroundTask.cs

#LineLine coverage
 1using Elsa.Common;
 2
 3namespace Elsa.Diagnostics.StructuredLogs.Persistence.Relational.Services;
 4
 05public class StructuredLogWriteBufferBackgroundTask(StructuredLogWriteBuffer writeBuffer) : IBackgroundTask
 6{
 7    private volatile bool _started;
 8
 9    public async Task StartAsync(CancellationToken cancellationToken)
 10    {
 011        if (_started)
 012            return;
 13
 014        await writeBuffer.StartAsync(cancellationToken);
 015        _started = true;
 016    }
 17
 18    public Task ExecuteAsync(CancellationToken cancellationToken)
 19    {
 020        return Task.CompletedTask;
 21    }
 22
 23    public async Task StopAsync(CancellationToken cancellationToken)
 24    {
 025        if (!_started)
 026            return;
 27
 028        _started = false;
 029        await writeBuffer.StopAsync(cancellationToken);
 030    }
 31}