< Summary

Information

Class:	NexusLabs.Needlr.AgentFramework.Workflows.Diagnostics.ToolCallCollector
Assembly:	NexusLabs.Needlr.AgentFramework.Workflows
File(s):	/home/runner/work/needlr/needlr/src/NexusLabs.Needlr.AgentFramework.Workflows/Diagnostics/ToolCallCollector.cs

Line coverage

57%

Branch coverage

50%

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%	2	1	0%
DrainToolCalls()	50%	2	2	60%

#	Line	Line coverage
	`1`	`using System.Collections.Concurrent;`
	`2`
	`3`	`using NexusLabs.Needlr.AgentFramework.Diagnostics;`
	`4`
	`5`	`namespace NexusLabs.Needlr.AgentFramework.Workflows.Diagnostics;`
	`6`
	`7`	`/// <summary>`
	`8`	`/// Thread-safe collector for tool call diagnostics captured by the function-calling`
	`9`	`/// middleware. Analogous to <see cref="DiagnosticsChatClientMiddleware"/>'s completion`
	`10`	`/// collection, ensuring tool calls are not lost when AsyncLocal builders don't propagate.`
	`11`	`/// </summary>`
	`12`	`internal sealed class ToolCallCollector : IToolCallCollector`
	`13`	`{`
35	`14`	`private readonly ConcurrentQueue<ToolCallDiagnostics> _toolCalls = new();`
	`15`
	`16`	`internal void Add(ToolCallDiagnostics diagnostics) =>`
0	`17`	`_toolCalls.Enqueue(diagnostics);`
	`18`
	`19`	`/// <inheritdoc />`
	`20`	`public IReadOnlyList<ToolCallDiagnostics> DrainToolCalls()`
	`21`	`{`
18	`22`	`var results = new List<ToolCallDiagnostics>();`
18	`23`	`while (_toolCalls.TryDequeue(out var toolCall))`
	`24`	`{`
0	`25`	`results.Add(toolCall);`
0	`26`	`}`
18	`27`	`return results;`
	`28`	`}`
	`29`	`}`