Path Lines of Code tests/Directory.Build.props 26 tests/Epam.Kafka.HealthChecks.Tests/Epam.Kafka.HealthChecks.Tests.csproj 10 tests/Epam.Kafka.HealthChecks.Tests/HealthCheckTests.cs 83 tests/Epam.Kafka.HealthChecks.Tests/PublicApiTests.cs 12 tests/Epam.Kafka.PubSub.EntityFramework6.Tests/Epam.Kafka.PubSub.EntityFramework6.Tests.csproj 29 tests/Epam.Kafka.PubSub.EntityFramework6.Tests/Helpers/TestContext.cs 19 tests/Epam.Kafka.PubSub.EntityFramework6.Tests/Helpers/TestWithContext.cs 25 tests/Epam.Kafka.PubSub.EntityFramework6.Tests/PublicApiTests.cs 13 tests/Epam.Kafka.PubSub.EntityFrameworkCore.Tests/DbContextEntityPublicationHandlerTests.cs 167 tests/Epam.Kafka.PubSub.EntityFrameworkCore.Tests/DbContextEntitySubscriptionHandlerTests.cs 40 tests/Epam.Kafka.PubSub.EntityFrameworkCore.Tests/DbContextOffsetsStorageTests.cs 106 tests/Epam.Kafka.PubSub.EntityFrameworkCore.Tests/Epam.Kafka.PubSub.EntityFrameworkCore.Tests.csproj 20 tests/Epam.Kafka.PubSub.EntityFrameworkCore.Tests/Helpers/TestContext.cs 18 tests/Epam.Kafka.PubSub.EntityFrameworkCore.Tests/Helpers/TestDbContextEntityPublicationHandler.cs 54 tests/Epam.Kafka.PubSub.EntityFrameworkCore.Tests/Helpers/TestDbContextEntitySubscriptionHandler.cs 46 tests/Epam.Kafka.PubSub.EntityFrameworkCore.Tests/Helpers/TestEntityDb.cs 23 tests/Epam.Kafka.PubSub.EntityFrameworkCore.Tests/Helpers/TestWithContext.cs 29 tests/Epam.Kafka.PubSub.EntityFrameworkCore.Tests/PublicApiTests.cs 17 tests/Epam.Kafka.PubSub.IntegrationTests/Epam.Kafka.PubSub.IntegrationTests.csproj 10 tests/Epam.Kafka.PubSub.IntegrationTests/IntegrationTestsExtensions.cs 51 tests/Epam.Kafka.PubSub.IntegrationTests/Publication/PubServiceErrorTests.cs 82 tests/Epam.Kafka.PubSub.IntegrationTests/Publication/PubServiceSuccessTests.cs 118 tests/Epam.Kafka.PubSub.IntegrationTests/Publication/TransactionsTests.cs 93 tests/Epam.Kafka.PubSub.IntegrationTests/SubscribeTests.cs 9 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/CombinedState/HandlerErrorTests.cs 101 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/CombinedState/PauseTests.cs 206 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/CombinedState/ReadTests.cs 159 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/CombinedState/ResetTests.cs 178 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/CombinedState/SerializationErrorTests.cs 111 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/CombinedState/StateErrorTests.cs 89 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/ExternalState/HandlerErrorTests.cs 144 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/ExternalState/PauseTests.cs 196 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/ExternalState/ReadTests.cs 159 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/ExternalState/ReplicationTests.cs 161 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/ExternalState/ResetTests.cs 186 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/ExternalState/SerializationErrorTests.cs 101 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/ExternalState/StateErrorTests.cs 86 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/InternalState/HandlerErrorTests.cs 80 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/InternalState/ReadTests.cs 122 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/InternalState/ReplicationTests.cs 306 tests/Epam.Kafka.PubSub.IntegrationTests/Subscription/InternalState/SerializationErrorTests.cs 86 tests/Epam.Kafka.PubSub.Tests/Epam.Kafka.PubSub.Tests.csproj 10 tests/Epam.Kafka.PubSub.Tests/Helpers/AssertExtensions.cs 82 tests/Epam.Kafka.PubSub.Tests/Helpers/IterationMock.cs 43 tests/Epam.Kafka.PubSub.Tests/Helpers/TestConversionHandler.cs 73 tests/Epam.Kafka.PubSub.Tests/Helpers/TestDeserializer.cs 48 tests/Epam.Kafka.PubSub.Tests/Helpers/TestException.cs 14 tests/Epam.Kafka.PubSub.Tests/Helpers/TestExtensions.cs 40 tests/Epam.Kafka.PubSub.Tests/Helpers/TestObserver.cs 117 tests/Epam.Kafka.PubSub.Tests/Helpers/TestOffsetsStorage.cs 119 tests/Epam.Kafka.PubSub.Tests/Helpers/TestPublicationHandler.cs 93 tests/Epam.Kafka.PubSub.Tests/Helpers/TestSerializer.cs 43 tests/Epam.Kafka.PubSub.Tests/Helpers/TestSubscriptionHandler.cs 60 tests/Epam.Kafka.PubSub.Tests/PubSubContextTests.cs 152 tests/Epam.Kafka.PubSub.Tests/PublicApiTests.cs 13 tests/Epam.Kafka.PubSub.Tests/Publication/PubServiceErrorTests.cs 141 tests/Epam.Kafka.PubSub.Tests/Publication/PubServiceStartupTests.cs 82 tests/Epam.Kafka.PubSub.Tests/Publication/PublicationHealthCheckTests.cs 54 tests/Epam.Kafka.PubSub.Tests/Replication/ReplicationServiceStartupTests.cs 63 tests/Epam.Kafka.PubSub.Tests/Subscription/SubServiceStartupTests.cs 57 tests/Epam.Kafka.PubSub.Tests/Subscription/SubscriptionHealthCheckTests.cs 56 tests/Epam.Kafka.Tests/Common/CollectionLoggerProvider.cs 39 tests/Epam.Kafka.Tests/Common/MockCluster.cs 107 tests/Epam.Kafka.Tests/Common/PublicApiHelper.cs 18 tests/Epam.Kafka.Tests/Common/TestEntityKafka.cs 33 tests/Epam.Kafka.Tests/Common/TestLoggerProvider.cs 46 tests/Epam.Kafka.Tests/Common/TestWithServices.cs 49 tests/Epam.Kafka.Tests/Epam.Kafka.Tests.csproj 15 tests/Epam.Kafka.Tests/KafkaBuilderTests.cs 29 tests/Epam.Kafka.Tests/KafkaClientExtensionsTests.cs 12 tests/Epam.Kafka.Tests/KafkaConfigExtensionsTests.cs 59 tests/Epam.Kafka.Tests/KafkaFactoryTests.cs 344 tests/Epam.Kafka.Tests/OAuthRefreshResultTests.cs 23 tests/Epam.Kafka.Tests/PublicApiTests.cs 12 tests/kafka-start.cmd 1 tests/kafka-stop.cmd 1