< Summary

Information

Class:	Elsa.Workflows.Runtime.BookmarkQueueSignaler
Assembly:	Elsa.Workflows.Runtime
File(s):	/home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Workflows.Runtime/Services/BookmarkQueueSignaler.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%
AwaitAsync(...)	100%	1	1	100%
TriggerAsync(...)	100%	1	1	100%

#	Line	Line coverage
	`1`	`using System.Threading.Channels;`
	`2`
	`3`	`namespace Elsa.Workflows.Runtime;`
	`4`
	`5`	`public class BookmarkQueueSignaler : IBookmarkQueueSignaler`
	`6`	`{`
	`7`	`private readonly Channel<object?> _channel;`
	`8`
140	`9`	`public BookmarkQueueSignaler()`
	`10`	`{`
140	`11`	`var options = new BoundedChannelOptions(1)`
140	`12`	`{`
140	`13`	`SingleReader = true,`
140	`14`	`SingleWriter = false,`
140	`15`	`AllowSynchronousContinuations = false`
140	`16`	`};`
140	`17`	`_channel = Channel.CreateBounded<object?>(options);`
140	`18`	`}`
	`19`
	`20`	`public Task AwaitAsync(CancellationToken cancellationToken)`
	`21`	`{`
485	`22`	`return _channel.Reader.ReadAsync(cancellationToken).AsTask();`
	`23`	`}`
	`24`
	`25`	`public Task TriggerAsync(CancellationToken cancellationToken)`
	`26`	`{`
1026	`27`	`_channel.Writer.TryWrite(null);`
1026	`28`	`return Task.CompletedTask;`
	`29`	`}`
	`30`	`}`