< Summary

Information

Class:	Elsa.Common.Multitenancy.TenantBackgroundWorkQueue
Assembly:	Elsa.Common
File(s):	/home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Common/Multitenancy/Implementations/TenantBackgroundWorkQueue.cs

Line coverage

100%

Branch coverage

N/A

Method coverage

Feature is only available for sponsors

Metrics

Method	Branch coverage	Crap Score	Cyclomatic complexity	Line coverage
.ctor()	100%	1	1	100%
EnqueueAsync(...)	100%	1	1	100%
DequeueAllAsync(...)	100%	1	1	100%

#	Line	Line coverage
	`1`	`using System.Threading.Channels;`
	`2`
	`3`	`namespace Elsa.Common.Multitenancy;`
	`4`
	`5`	`public class TenantBackgroundWorkQueue : ITenantBackgroundWorkQueue`
	`6`	`{`
13	`7`	`private readonly Channel<TenantBackgroundWorkItem> _channel = Channel.CreateUnbounded<TenantBackgroundWorkItem>(new`
13	`8`	`{`
13	`9`	`SingleReader = true,`
13	`10`	`SingleWriter = false`
13	`11`	`});`
	`12`
	`13`	`public ValueTask EnqueueAsync(TenantBackgroundWorkItem workItem, CancellationToken cancellationToken = default)`
	`14`	`{`
13	`15`	`ArgumentNullException.ThrowIfNull(workItem);`
13	`16`	`return _channel.Writer.WriteAsync(workItem, cancellationToken);`
	`17`	`}`
	`18`
	`19`	`public IAsyncEnumerable<TenantBackgroundWorkItem> DequeueAllAsync(CancellationToken cancellationToken = default)`
	`20`	`{`
13	`21`	`return _channel.Reader.ReadAllAsync(cancellationToken);`
	`22`	`}`
	`23`	`}`