path	# lines of code
benchmarks/Compression/MessageSize.cs	6
benchmarks/Compression/MessageBytes.cs	53
benchmarks/Compression/Decompress.cs	64
benchmarks/Compression/Messages.proto	25
benchmarks/Compression/Compress.cs	45
benchmarks/Compression/MessageType.cs	6
benchmarks/Compression/Program.cs	22
benchmarks/Compression/Factories.cs	39
src/DotPulsar/RoundRobinPartitionRouter.cs	18
src/DotPulsar/ConsumerOptions.cs	66
src/DotPulsar/SubscriptionInitialPosition.cs	7
src/DotPulsar/ProducerAccessMode.cs	8
src/DotPulsar/CompressionType.cs	10
src/DotPulsar/SchemaInfo.cs	29
src/DotPulsar/MessageMetadata.cs	98
src/DotPulsar/Extensions/PulsarClientBuilderExtensions.cs	16
src/DotPulsar/Extensions/ReaderExtensions.cs	25
src/DotPulsar/Extensions/ReceiveExtensions.cs	32
src/DotPulsar/Extensions/ReaderBuilderExtensions.cs	30
src/DotPulsar/Extensions/ProducerBuilderExtensions.cs	30
src/DotPulsar/Extensions/SeekExtensions.cs	9
src/DotPulsar/Extensions/PulsarClientExtensions.cs	20
src/DotPulsar/Extensions/StateExtensions.cs	59
src/DotPulsar/Extensions/MessageExtensions.cs	13
src/DotPulsar/Extensions/ConsumerExtensions.cs	44
src/DotPulsar/Extensions/ProducerExtensions.cs	28
src/DotPulsar/Extensions/MessageMetadataExtensions.cs	10
src/DotPulsar/Extensions/ConsumerBuilderExtensions.cs	37
src/DotPulsar/Extensions/StateHolderExtensions.cs	91
src/DotPulsar/Extensions/MessageBuilderExtensions.cs	10
src/DotPulsar/Extensions/SendExtensions.cs	27
src/DotPulsar/Extensions/SendChannelExtensions.cs	26
src/DotPulsar/Internal/SubscribeResponse.cs	8
src/DotPulsar/Internal/StateTask.cs	17
src/DotPulsar/Internal/ConnectionState.cs	7
src/DotPulsar/Internal/PulsarClientFactory.cs	8
src/DotPulsar/Internal/Awaiter.cs	35
src/DotPulsar/Internal/ProducerChannelFactory.cs	73
src/DotPulsar/Internal/AsyncQueueWithCursor.cs	218
src/DotPulsar/Internal/Connection.cs	308
src/DotPulsar/Internal/Producer.cs	289
src/DotPulsar/Internal/SubConsumer.cs	189
src/DotPulsar/Internal/SendChannel.cs	25
src/DotPulsar/Internal/MessageProcessor.cs	190
src/DotPulsar/Internal/MessageBuilder.cs	75
src/DotPulsar/Internal/ExceptionHandlerPipeline.cs	23
src/DotPulsar/Internal/BatchHandler.cs	104
src/DotPulsar/Internal/SubReader.cs	109
src/DotPulsar/Internal/Extensions/MessagePackageExtensions.cs	19
src/DotPulsar/Internal/Extensions/ReadOnlySequenceExtensions.cs	68
src/DotPulsar/Internal/Extensions/CommandExtensions.cs	171
src/DotPulsar/Internal/Extensions/MessageIdDataExtensions.cs	15
src/DotPulsar/Internal/Extensions/MessageMetadataExtensions.cs	42
src/DotPulsar/Internal/Extensions/ActivityExtensions.cs	30
src/DotPulsar/Internal/Extensions/TypeExtensions.cs	19
src/DotPulsar/Internal/SendPackage.cs	10
src/DotPulsar/Internal/AsyncQueue.cs	87
src/DotPulsar/Internal/StateChanged.cs	7
src/DotPulsar/Internal/PingPongHandler.cs	66
src/DotPulsar/Internal/ProducerProcess.cs	56
src/DotPulsar/Internal/MessageMetadataObjectPool.cs	21
src/DotPulsar/Internal/ConnectionPool.cs	218
src/DotPulsar/Internal/Consumer.cs	392
src/DotPulsar/Internal/DefaultExceptionHandler.cs	48
src/DotPulsar/Internal/RequestResponseHandler.cs	135
src/DotPulsar/Internal/ChannelState.cs	13
src/DotPulsar/Internal/ConsumerBuilder.cs	135
src/DotPulsar/Internal/ChannelManager.cs	236
src/DotPulsar/Internal/SubProducer.cs	188
src/DotPulsar/Internal/Events/ChannelActivated.cs	8
src/DotPulsar/Internal/Events/ChannelClosedByServer.cs	8
src/DotPulsar/Internal/Events/ProducerWaitingForExclusive.cs	8
src/DotPulsar/Internal/Events/ChannelConnected.cs	8
src/DotPulsar/Internal/Events/ProducerDisposed.cs	8
src/DotPulsar/Internal/Events/SendReceiptWrongOrdering.cs	8
src/DotPulsar/Internal/Events/ReaderCreated.cs	8
src/DotPulsar/Internal/Events/ProducerCreated.cs	8
src/DotPulsar/Internal/Events/ChannelReachedEndOfTopic.cs	8
src/DotPulsar/Internal/Events/ExecutorFaulted.cs	12
src/DotPulsar/Internal/Events/ConsumerCreated.cs	8
src/DotPulsar/Internal/Events/ChannelDeactivated.cs	8
src/DotPulsar/Internal/Events/ReaderDisposed.cs	8
src/DotPulsar/Internal/Events/ConsumerDisposed.cs	8
src/DotPulsar/Internal/Events/ChannelDisconnected.cs	8
src/DotPulsar/Internal/Events/ChannelUnsubscribed.cs	8
src/DotPulsar/Internal/NotReadyChannel.cs	29
src/DotPulsar/Internal/SequenceBuilder.cs	66
src/DotPulsar/Internal/Executor.cs	154
src/DotPulsar/Internal/SequenceId.cs	11
src/DotPulsar/Internal/Abstractions/ICompressorFactory.cs	8
src/DotPulsar/Internal/Abstractions/IRequest.cs	8
src/DotPulsar/Internal/Abstractions/IProducerChannel.cs	8
src/DotPulsar/Internal/Abstractions/IRegisterEvent.cs	6
src/DotPulsar/Internal/Abstractions/IEvent.cs	5
src/DotPulsar/Internal/Abstractions/IConnectionPool.cs	9
src/DotPulsar/Internal/Abstractions/IDequeue.cs	5
src/DotPulsar/Internal/Abstractions/Process.cs	82
src/DotPulsar/Internal/Abstractions/IConnection.cs	25
src/DotPulsar/Internal/Abstractions/IConsumerChannel.cs	13
src/DotPulsar/Internal/Abstractions/IMessageFactory.cs	9
src/DotPulsar/Internal/Abstractions/IEnqueue.cs	6
src/DotPulsar/Internal/Abstractions/IProducerChannelFactory.cs	5
src/DotPulsar/Internal/Abstractions/IContainsChannel.cs	7
src/DotPulsar/Internal/Abstractions/IDecompressorFactory.cs	8
src/DotPulsar/Internal/Abstractions/ICompress.cs	6
src/DotPulsar/Internal/Abstractions/IProcess.cs	7
src/DotPulsar/Internal/Abstractions/IDecompress.cs	6
src/DotPulsar/Internal/Abstractions/IConsumerChannelFactory.cs	5
src/DotPulsar/Internal/Abstractions/IExecute.cs	16
src/DotPulsar/Internal/Abstractions/IChannel.cs	14
src/DotPulsar/Internal/Abstractions/IStateManager.cs	7
src/DotPulsar/Internal/Abstractions/IPulsarStream.cs	7
src/DotPulsar/Internal/ActionExceptionHandler.cs	13
src/DotPulsar/Internal/Serializer.cs	47
src/DotPulsar/Internal/PulsarApi/GeneratedCode.cs	3124
src/DotPulsar/Internal/ProducerBuilder.cs	101
src/DotPulsar/Internal/ReaderProcess.cs	50
src/DotPulsar/Internal/EnumLookup.cs	17
src/DotPulsar/Internal/MonitorState.cs	57
src/DotPulsar/Internal/Connector.cs	146
src/DotPulsar/Internal/MessagePackage.cs	16
src/DotPulsar/Internal/FuncStateChangedHandler.cs	14
src/DotPulsar/Internal/ConsumerChannelFactory.cs	44
src/DotPulsar/Internal/Channel.cs	77
src/DotPulsar/Internal/ChunkingPipeline.cs	74
src/DotPulsar/Internal/SendOp.cs	21
src/DotPulsar/Internal/ChannelManagerState.cs	7
src/DotPulsar/Internal/ProducerChannel.cs	82
src/DotPulsar/Internal/ExecutorState.cs	7
src/DotPulsar/Internal/ConsumerChannel.cs	188
src/DotPulsar/Internal/DotPulsarActivitySource.cs	57
src/DotPulsar/Internal/RequestId.cs	12
src/DotPulsar/Internal/Requests/StandardRequest.cs	42
src/DotPulsar/Internal/Requests/ConnectRequest.cs	21
src/DotPulsar/Internal/Requests/SendRequest.cs	32
src/DotPulsar/Internal/Message.cs	57
src/DotPulsar/Internal/UIntUnion.cs	33
src/DotPulsar/Internal/TokenAuthentication.cs	14
src/DotPulsar/Internal/Constants.cs	43
src/DotPulsar/Internal/IdLookup.cs	74
src/DotPulsar/Internal/PulsarClientBuilder.cs	134
src/DotPulsar/Internal/MessageFactory.cs	74
src/DotPulsar/Internal/AsyncLock.cs	102
src/DotPulsar/Internal/PingPongHandlerState.cs	8
src/DotPulsar/Internal/StateTaskCollection.cs	58
src/DotPulsar/Internal/PulsarStream.cs	122
src/DotPulsar/Internal/Reader.cs	255
src/DotPulsar/Internal/Exceptions/UnexpectedResponseException.cs	7
src/DotPulsar/Internal/Exceptions/AsyncQueueWithCursorNoItemException.cs	6
src/DotPulsar/Internal/Exceptions/ProducerSendReceiptOrderingException.cs	7
src/DotPulsar/Internal/Exceptions/ConnectionDisposedException.cs	5
src/DotPulsar/Internal/Exceptions/SendChannelCompletedException.cs	5
src/DotPulsar/Internal/Exceptions/AsyncLockDisposedException.cs	5
src/DotPulsar/Internal/Exceptions/PulsarStreamDisposedException.cs	5
src/DotPulsar/Internal/Exceptions/AsyncQueueDisposedException.cs	5
src/DotPulsar/Internal/Exceptions/AsyncQueueWithCursorDisposedException.cs	5
src/DotPulsar/Internal/StateManager.cs	60
src/DotPulsar/Internal/ProducerResponse.cs	13
src/DotPulsar/Internal/CancelableCompletionSource.cs	27
src/DotPulsar/Internal/DotPulsarMeter.cs	52
src/DotPulsar/Internal/ActionStateChangedHandler.cs	17
src/DotPulsar/Internal/ReaderBuilder.cs	81
src/DotPulsar/Internal/Compression/CompressionFactories.cs	47
src/DotPulsar/Internal/Compression/SnappyCompression.cs	79
src/DotPulsar/Internal/Compression/ZstdSharpCompression.cs	126
src/DotPulsar/Internal/Compression/Lz4Compression.cs	143
src/DotPulsar/Internal/Compression/ZstdCompression.cs	111
src/DotPulsar/Internal/Compression/Decompressor.cs	17
src/DotPulsar/Internal/Compression/CompressorFactory.cs	15
src/DotPulsar/Internal/Compression/Compressor.cs	19
src/DotPulsar/Internal/Compression/BuiltinZlibCompression.cs	50
src/DotPulsar/Internal/Compression/CompressionTester.cs	15
src/DotPulsar/Internal/Compression/DecompressorFactory.cs	15
src/DotPulsar/Internal/ExecutionResult.cs	11
src/DotPulsar/Internal/FuncExceptionHandler.cs	10
src/DotPulsar/Internal/ProcessManager.cs	55
src/DotPulsar/Internal/Crc32C.cs	61
src/DotPulsar/Internal/ConsumerProcess.cs	63
src/DotPulsar/MessageId.cs	134
src/DotPulsar/ConsumerState.cs	13
src/DotPulsar/SchemaType.cs	26
src/DotPulsar/Abstractions/IProducer.cs	6
src/DotPulsar/Abstractions/IMessage.cs	25
src/DotPulsar/Abstractions/IConsumer.cs	14
src/DotPulsar/Abstractions/IReaderBuilder.cs	13
src/DotPulsar/Abstractions/IPulsarClientBuilder.cs	19
src/DotPulsar/Abstractions/IGetLastMessageIds.cs	5
src/DotPulsar/Abstractions/ISchema.cs	8
src/DotPulsar/Abstractions/IReader.cs	6
src/DotPulsar/Abstractions/IMessageBuilder.cs	17
src/DotPulsar/Abstractions/IReaderOfT.cs	3
src/DotPulsar/Abstractions/IHandleStateChanged.cs	6
src/DotPulsar/Abstractions/IStateHolder.cs	5
src/DotPulsar/Abstractions/IAuthentication.cs	6
src/DotPulsar/Abstractions/ISendChannel.cs	7
src/DotPulsar/Abstractions/IProducerOfT.cs	6
src/DotPulsar/Abstractions/IMessageRouter.cs	6
src/DotPulsar/Abstractions/IConsumerOfT.cs	3
src/DotPulsar/Abstractions/IProducerBuilder.cs	16
src/DotPulsar/Abstractions/IHandleException.cs	5
src/DotPulsar/Abstractions/IReceive.cs	5
src/DotPulsar/Abstractions/ISeek.cs	6
src/DotPulsar/Abstractions/IConsumerBuilder.cs	20
src/DotPulsar/Abstractions/IState.cs	8
src/DotPulsar/Abstractions/IPulsarClient.cs	8
src/DotPulsar/Abstractions/ISend.cs	5
src/DotPulsar/Abstractions/IMessageOfT.cs	5
src/DotPulsar/ProcessingOptions.cs	70
src/DotPulsar/Schema.cs	34
src/DotPulsar/PulsarClient.cs	102
src/DotPulsar/ProducerStateChanged.cs	13
src/DotPulsar/ConsumerStateChanged.cs	13
src/DotPulsar/SubscriptionType.cs	9
src/DotPulsar/ProducerOptions.cs	31
src/DotPulsar/RegexSubscriptionMode.cs	7
src/DotPulsar/ExceptionContext.cs	15
src/DotPulsar/ReaderState.cs	11
src/DotPulsar/Schemas/ByteSequenceSchema.cs	14
src/DotPulsar/Schemas/DoubleSchema.cs	28
src/DotPulsar/Schemas/BooleanSchema.cs	26
src/DotPulsar/Schemas/AvroGenericRecordSchema.cs	216
src/DotPulsar/Schemas/StringSchema.cs	64
src/DotPulsar/Schemas/IntegerSchema.cs	28
src/DotPulsar/Schemas/AvroISpecificRecordSchema.cs	185
src/DotPulsar/Schemas/ByteArraySchema.cs	14
src/DotPulsar/Schemas/ByteSchema.cs	19
src/DotPulsar/Schemas/LongSchema.cs	28
src/DotPulsar/Schemas/TimestampSchema.cs	34
src/DotPulsar/Schemas/TimeSchema.cs	23
src/DotPulsar/Schemas/ShortSchema.cs	28
src/DotPulsar/Schemas/FloatSchema .cs	28
src/DotPulsar/SinglePartitionRouter.cs	24
src/DotPulsar/AuthenticationFactory.cs	8
src/DotPulsar/ReaderStateChanged.cs	13
src/DotPulsar/Exceptions/TransactionCoordinatorNotFoundException.cs	6
src/DotPulsar/Exceptions/FaultedException.cs	6
src/DotPulsar/Exceptions/InvalidTransactionStatusException.cs	6
src/DotPulsar/Exceptions/ProducerBusyException.cs	5
src/DotPulsar/Exceptions/TransactionConflictException.cs	6
src/DotPulsar/Exceptions/ChecksumException.cs	5
src/DotPulsar/Exceptions/UnknownException.cs	6
src/DotPulsar/Exceptions/ProducerFaultedException.cs	6
src/DotPulsar/Exceptions/ConsumerAssignException.cs	5
src/DotPulsar/Exceptions/ConfigurationException.cs	6
src/DotPulsar/Exceptions/TopicTerminatedException.cs	5
src/DotPulsar/Exceptions/ConsumerDisposedException.cs	5
src/DotPulsar/Exceptions/CompressionException.cs	6
src/DotPulsar/Exceptions/ConsumerClosedException.cs	6
src/DotPulsar/Exceptions/SubscriptionNotFoundException.cs	5
src/DotPulsar/Exceptions/UnsupportedVersionException.cs	5
src/DotPulsar/Exceptions/NotAllowedException.cs	6
src/DotPulsar/Exceptions/PersistenceException.cs	5
src/DotPulsar/Exceptions/PulsarClientClosedException.cs	6
src/DotPulsar/Exceptions/TopicNotFoundException.cs	5
src/DotPulsar/Exceptions/TooLargeMessageException.cs	12
src/DotPulsar/Exceptions/IncompatibleSchemaException.cs	5
src/DotPulsar/Exceptions/ConsumerNotFoundException.cs	5
src/DotPulsar/Exceptions/PulsarClientDisposedException.cs	5
src/DotPulsar/Exceptions/ProcessingException.cs	5
src/DotPulsar/Exceptions/InvalidTopicsPatternException.cs	5
src/DotPulsar/Exceptions/ProducerDisposedException.cs	5
src/DotPulsar/Exceptions/ConsumerFaultedException.cs	6
src/DotPulsar/Exceptions/ReaderClosedException.cs	6
src/DotPulsar/Exceptions/AuthorizationException.cs	5
src/DotPulsar/Exceptions/AuthenticationException.cs	6
src/DotPulsar/Exceptions/InvalidSchemeException.cs	6
src/DotPulsar/Exceptions/InvalidTopicNameException.cs	5
src/DotPulsar/Exceptions/ConsumerBusyException.cs	5
src/DotPulsar/Exceptions/TooManyRequestsException.cs	5
src/DotPulsar/Exceptions/ProducerClosedException.cs	6
src/DotPulsar/Exceptions/ServiceNotReadyException.cs	5
src/DotPulsar/Exceptions/ReaderFaultedException.cs	6
src/DotPulsar/Exceptions/ProducerFencedException.cs	5
src/DotPulsar/Exceptions/MetadataException.cs	5
src/DotPulsar/Exceptions/ProducerBlockedQuotaExceededException.cs	5
src/DotPulsar/Exceptions/ChannelNotReadyException.cs	6
src/DotPulsar/Exceptions/ConnectionSecurityException.cs	6
src/DotPulsar/Exceptions/SchemaSerializationException.cs	6
src/DotPulsar/Exceptions/SchemaException.cs	6
src/DotPulsar/Exceptions/DotPulsarException.cs	6
src/DotPulsar/Exceptions/ReaderDisposedException.cs	5
src/DotPulsar/ProducerState.cs	12
src/DotPulsar/FaultAction.cs	8
src/DotPulsar/ReaderOptions.cs	26
src/DotPulsar/EncryptionPolicy.cs	9