< Summary - CoreWCF Coverage — PR #1766

Information

Class:	CoreWCF.ServiceModel.Channels.KafkaChannelHelpers
Assembly:	CoreWCF.Kafka.Client
File(s):	/home/runner/work/CoreWCF/CoreWCF/src/CoreWCF.Kafka.Client/src/CoreWCF/ServiceModel/Channels/Helpers/KafkaChannelHelpers.cs

Line coverage

33%

Branch coverage

50%

Method coverage

Feature is only available for sponsors

Metrics

Method	Branch coverage	Cyclomatic complexity	NPath complexity	Sequence coverage
ConvertKafkaException(...)	50%	4	4	33.33%

#	Line	Line coverage
	`1`	`// Licensed to the .NET Foundation under one or more agreements.`
	`2`	`// The .NET Foundation licenses this file to you under the MIT license.`
	`3`
	`4`	`using System;`
	`5`	`using System.Globalization;`
	`6`	`using System.ServiceModel;`
	`7`	`using Confluent.Kafka;`
	`8`
	`9`	`namespace CoreWCF.ServiceModel.Channels;`
	`10`
	`11`	`internal static class KafkaChannelHelpers`
	`12`	`{`
	`13`	`public static Exception ConvertKafkaException(KafkaException kafkaException)`
	`14`	`{`
1	`15`	`if (kafkaException.Error.IsLocalError && kafkaException.Error.Code == ErrorCode.Local_MsgTimedOut)`
	`16`	`{`
1	`17`	`throw new TimeoutException(SR.KafkaSendTimeout, kafkaException);`
	`18`	`}`
	`19`
0	`20`	`return new CommunicationException(`
0	`21`	`string.Format(CultureInfo.CurrentCulture,`
0	`22`	`"An error ({0}: {1}) occurred while transmitting data.", kafkaException.Error.Code, kafkaException.Error`
0	`23`	`kafkaException);`
	`24`	`}`
	`25`	`}`