< Summary

Information

Class:	CounterpointCollective.Dataflow.Notifying.NotifyingPropagatorBlock<T1, T2>
Assembly:	Dataflow.Composable
File(s):	/builds/counterpointcollective/composabledataflowblocks/Source/Dataflow.Composable/DataFlow/Notifying/NotifyingPropagatorBlock.cs

Line coverage

100%

Covered lines:	3
Uncovered lines:	0
Coverable lines:	3
Total lines:	16
Line coverage:	100%

Branch coverage

N/A

Covered branches:	0
Total branches:	0
Branch coverage:	N/A

Method coverage

Feature is only available for sponsors

Upgrade to PRO version

Metrics

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

File(s)

/builds/counterpointcollective/composabledataflowblocks/Source/Dataflow.Composable/DataFlow/Notifying/NotifyingPropagatorBlock.cs

	#	Line		Line coverage
		`1`		`using System.Threading.Tasks.Dataflow;`
		`2`
		`3`		`namespace CounterpointCollective.Dataflow.Notifying`
		`4`		`{`
		`5`		`public class NotifyingPropagatorBlock<I, O> : NotifyingSourceBlock<O>, IPropagatorBlock<I,O>`
		`6`		`{`
		`7`		`private readonly ITargetBlock<I> _targetBlock;`
		`8`
	42	`9`		`public NotifyingPropagatorBlock(IPropagatorBlock<I, O> inner, ConfigureHooks<O> hooks) : base(inner, hooks)`
	42	`10`		`=> _targetBlock = inner;`
		`11`
		`12`		`/// <exclude/>`
		`13`		`public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, I messageValue, ISourceBlock<I>?`
	503	`14`		`=> _targetBlock.OfferMessage(messageHeader, messageValue, source, consumeToAccept);`
		`15`		`}`
		`16`		`}`

Methods/Properties

.ctor(System.Threading.Tasks.Dataflow.IPropagatorBlock`2<I,O>,CounterpointCollective.Dataflow.Notifying.ConfigureHooks`1<O>)
OfferMessage(System.Threading.Tasks.Dataflow.DataflowMessageHeader,I,System.Threading.Tasks.Dataflow.ISourceBlock`1<I>,System.Boolean)