< Summary - Kestrun — Combined Coverage

Information

Class:	Kestrun.Callback.InMemoryCallbackDispatcher
Assembly:	Kestrun
File(s):	/home/runner/work/Kestrun/Kestrun/src/CSharp/Kestrun/Callback/InMemoryCallbackDispatcher.cs
Tag:	Kestrun/Kestrun@ca54e35c77799b76774b3805b6f075cdbc0c5fbe

Line coverage

100%

Branch coverage

N/A

Method coverage

Feature is only available for sponsors

Coverage history

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

#	Line	Line coverage
	`1`	`namespace Kestrun.Callback;`
	`2`
	`3`	`/// <summary>`
	`4`	`/// In-memory dispatcher for enqueuing callback requests.`
	`5`	`/// </summary>`
	`6`	`/// <remarks>`
	`7`	`/// Initializes a new instance of the <see cref="InMemoryCallbackDispatcher"/> class.`
	`8`	`/// </remarks>`
	`9`	`/// <param name="queue">The in-memory callback queue to use for dispatching callbacks.</param>`
1	`10`	`public sealed class InMemoryCallbackDispatcher(InMemoryCallbackQueue queue) : ICallbackDispatcher`
	`11`	`{`
1	`12`	`private readonly InMemoryCallbackQueue _queue = queue;`
	`13`
	`14`	`/// <summary>`
	`15`	`/// Enqueue a callback request for processing.`
	`16`	`/// </summary>`
	`17`	`/// <param name="request">The callback request to enqueue.</param>`
	`18`	`/// <param name="ct">Cancellation token.</param>`
	`19`	`public async ValueTask EnqueueAsync(CallbackRequest request, CancellationToken ct = default)`
1	`20`	`=> await _queue.Channel.Writer.WriteAsync(request, ct);`
	`21`	`}`