< Summary

Information

Class:	Elsa.Workflows.QueueBasedActivityScheduler
Assembly:	Elsa.Workflows.Core
File(s):	/home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Workflows.Core/Services/QueueBasedActivityScheduler.cs

Line coverage

87%

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%
get_HasAny()	100%	1	1	100%
Schedule(...)	100%	1	1	100%
Take()	100%	1	1	100%
List()	100%	1	1	100%
Any(...)	100%	2	1	0%
Find(...)	100%	1	1	100%
Clear()	100%	1	1	100%

#	Line	Line coverage
	`1`	`using Elsa.Workflows.Models;`
	`2`	`using JetBrains.Annotations;`
	`3`
	`4`	`namespace Elsa.Workflows;`
	`5`
	`6`	`/// <summary>`
	`7`	`/// A FIFO queue based activity scheduler.`
	`8`	`/// </summary>`
	`9`	`[PublicAPI]`
	`10`	`public class QueueBasedActivityScheduler : IActivityScheduler`
	`11`	`{`
855	`12`	`private readonly Queue<ActivityWorkItem> _queue = new();`
	`13`
	`14`	`/// <inheritdoc />`
3540	`15`	`public bool HasAny => _queue.Any();`
	`16`
	`17`	`/// <inheritdoc />`
3143	`18`	`public void Schedule(ActivityWorkItem workItem) => _queue.Enqueue(workItem);`
	`19`
	`20`	`/// <inheritdoc />`
3019	`21`	`public ActivityWorkItem Take() => _queue.Dequeue();`
	`22`
	`23`	`/// <inheritdoc />`
1504	`24`	`public IEnumerable<ActivityWorkItem> List() => _queue;`
	`25`
	`26`	`/// <inheritdoc />`
0	`27`	`public bool Any(Func<ActivityWorkItem, bool> predicate) => _queue.Any(predicate);`
	`28`
	`29`	`/// <inheritdoc />`
146	`30`	`public ActivityWorkItem? Find(Func<ActivityWorkItem, bool> predicate) => _queue.FirstOrDefault(predicate);`
	`31`
	`32`	`/// <inheritdoc />`
3	`33`	`public void Clear() => _queue.Clear();`
	`34`	`}`