< Summary

Information

Class:	ClientManager.Shared.Messaging.MessagePublishPipeline
Assembly:	ClientManager.Shared
File(s):	/home/runner/work/ClientManagerDemo/ClientManagerDemo/src/ClientManager/ClientManager.Shared/Messaging/Middleware/MessagePublishPipeline.cs

Line coverage

100%

Branch coverage

100%

Method coverage

Feature is only available for sponsors

Metrics

Method	Branch coverage	Crap Score	Cyclomatic complexity	Line coverage
.ctor()	100%	1	1	100%
ExecuteAsync(...)	100%	2	2	100%
Use(...)	100%	1	1	100%

#	Line	Line coverage
	`1`	`namespace ClientManager.Shared.Messaging;`
	`2`
	`3`	`public class MessagePublishPipeline`
	`4`	`{`
1	`5`	`readonly List<IMessagePublishMiddleware> _messagePublishMiddlewares = [];`
	`6`
	`7`	`public Task ExecuteAsync<T>(T message, MessagePublishDeleagte<T> finalHandler, CancellationToken cancellationToken)`
	`8`	`where T : IMessage`
	`9`	`{`
4	`10`	`MessagePublishDeleagte<T> next = finalHandler;`
	`11`
16	`12`	`foreach (var middleware in _messagePublishMiddlewares.AsEnumerable().Reverse())`
	`13`	`{`
4	`14`	`var current = middleware;`
4	`15`	`var nextCopy = next;`
8	`16`	`next = (msg, token) => current.InvokeAsync(msg, nextCopy, token);`
	`17`	`}`
	`18`
4	`19`	`return next(message, cancellationToken);`
	`20`	`}`
	`21`
	`22`	`public MessagePublishPipeline Use(IMessagePublishMiddleware middleware)`
	`23`	`{`
1	`24`	`_messagePublishMiddlewares.Add(middleware);`
1	`25`	`return this;`
	`26`	`}`
	`27`	`}`