< Summary

Information
Class: CounterpointCollective.Dataflow.ResizableBufferBlock<T>
Assembly: Dataflow.Composable
File(s): /builds/counterpointcollective/composabledataflowblocks/Source/Dataflow.Composable/DataFlow/ResizableBufferBlock.cs
Line coverage
100%
Covered lines: 7
Uncovered lines: 0
Coverable lines: 7
Total lines: 26
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

MethodBranch coverage Crap Score Cyclomatic complexity Line coverage
.ctor(...)100%11100%
get_TargetSide()100%11100%
get_SourceSide()100%11100%
get_Count()100%11100%
get_BoundedCapacity()100%11100%
set_BoundedCapacity(...)100%11100%

File(s)

/builds/counterpointcollective/composabledataflowblocks/Source/Dataflow.Composable/DataFlow/ResizableBufferBlock.cs

#LineLine coverage
 1using CounterpointCollective.Dataflow.Encapsulation;
 2using System.Threading.Tasks.Dataflow;
 3
 4namespace CounterpointCollective.Dataflow
 5{
 6    public sealed class ResizableBufferBlock<T> : AbstractEncapsulatedPropagatorBlock<T, T>, IResizablePropagatorBlock<T
 7    {
 8        private readonly BoundedPropagatorBlock<T,T> _inner;
 9
 1610        public ResizableBufferBlock(DataflowBlockOptions options, Action? onEntered = null) =>
 1611            _inner = new(new BufferBlock<T>(new() { CancellationToken = options.CancellationToken }), options.BoundedCap
 12
 13        /// <exclude/>
 1119814        protected override ITargetBlock<T> TargetSide => _inner;
 15
 16        /// <exclude/>
 1597917        protected override ISourceBlock<T> SourceSide => _inner;
 18
 63119        public int Count => _inner.Count;
 20
 21        public int BoundedCapacity {
 507222            get => _inner.BoundedCapacity;
 13023            set => _inner.BoundedCapacity = value;
 24        }
 25    }
 26}