< Summary

Information

Class:	NexusLabs.Needlr.AgentFramework.Collectors.AgentOutputCollector<T>
Assembly:	NexusLabs.Needlr.AgentFramework
File(s):	/home/runner/work/needlr/needlr/src/NexusLabs.Needlr.AgentFramework/Collectors/AgentOutputCollector.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%
Add(...)	100%	1	1	100%
get_Items()	100%	1	1	100%
get_Count()	100%	1	1	100%

#	Line	Line coverage
	`1`	`using System.Collections.Concurrent;`
	`2`
	`3`	`namespace NexusLabs.Needlr.AgentFramework.Collectors;`
	`4`
	`5`	`/// <summary>`
	`6`	`/// Default thread-safe implementation of <see cref="IAgentOutputCollector{T}"/>`
	`7`	`/// backed by a <see cref="ConcurrentQueue{T}"/>.`
	`8`	`/// </summary>`
	`9`	`[DoNotAutoRegister]`
	`10`	`public sealed class AgentOutputCollector<T> : IAgentOutputCollector<T>`
	`11`	`{`
11	`12`	`private readonly ConcurrentQueue<T> _items = new();`
	`13`
	`14`	`/// <inheritdoc />`
108	`15`	`public void Add(T item) => _items.Enqueue(item);`
	`16`
	`17`	`/// <inheritdoc />`
5	`18`	`public IReadOnlyList<T> Items => _items.ToArray();`
	`19`
	`20`	`/// <inheritdoc />`
5	`21`	`public int Count => _items.Count;`
	`22`	`}`