path	# lines of code
src/Directory.Build.props	6
src/DotPulsar/ReaderOptions.cs	23
src/DotPulsar/ProducerOptions.cs	29
src/DotPulsar/SchemaType.cs	26
src/DotPulsar/ExceptionContext.cs	18
src/DotPulsar/CompressionType.cs	10
src/DotPulsar/SubscriptionInitialPosition.cs	7
src/DotPulsar/ConsumerStateChanged.cs	13
src/DotPulsar/MessageMetadata.cs	99
src/DotPulsar/ReaderStateChanged.cs	13
src/DotPulsar/EncryptionPolicy.cs	9
src/DotPulsar/Internal/DefaultExceptionHandler.cs	52
src/DotPulsar/Internal/PulsarApi/GeneratedCode.cs	3124
src/DotPulsar/Internal/Crc32C.cs	61
src/DotPulsar/Internal/ExceptionHandlerPipeline.cs	27
src/DotPulsar/Internal/ExecutorState.cs	7
src/DotPulsar/Internal/UIntUnion.cs	33
src/DotPulsar/Internal/Constants.cs	45
src/DotPulsar/Internal/FuncStateChangedHandler.cs	18
src/DotPulsar/Internal/Channel.cs	82
src/DotPulsar/Internal/NotReadyChannel.cs	33
src/DotPulsar/Internal/SubscribeResponse.cs	8
src/DotPulsar/Internal/Message.cs	60
src/DotPulsar/Internal/MessageMetadataObjectPool.cs	21
src/DotPulsar/Internal/RequestResponseHandler.cs	130
src/DotPulsar/Internal/ChannelState.cs	13
src/DotPulsar/Internal/MessageBuilder.cs	79
src/DotPulsar/Internal/SendPackage.cs	10
src/DotPulsar/Internal/PulsarClientFactory.cs	10
src/DotPulsar/Internal/ChannelManager.cs	212
src/DotPulsar/Internal/Producer.cs	314
src/DotPulsar/Internal/ProcessManager.cs	62
src/DotPulsar/Internal/ProducerChannel.cs	85
src/DotPulsar/Internal/ConsumerBuilder.cs	107
src/DotPulsar/Internal/ProducerResponse.cs	12
src/DotPulsar/Internal/SendOp.cs	25
src/DotPulsar/Internal/IdLookup.cs	75
src/DotPulsar/Internal/MessageProcessor.cs	174
src/DotPulsar/Internal/PingPongHandler.cs	84
src/DotPulsar/Internal/DotPulsarMeter.cs	60
src/DotPulsar/Internal/SequenceBuilder.cs	70
src/DotPulsar/Internal/StateChanged.cs	7
src/DotPulsar/Internal/ActionExceptionHandler.cs	16
src/DotPulsar/Internal/SendChannel.cs	28
src/DotPulsar/Internal/AsyncLock.cs	96
src/DotPulsar/Internal/ActionStateChangedHandler.cs	21
src/DotPulsar/Internal/SequenceId.cs	13
src/DotPulsar/Internal/Exceptions/ProducerSendReceiptOrderingException.cs	9
src/DotPulsar/Internal/Exceptions/SendChannelCompletedException.cs	7
src/DotPulsar/Internal/Exceptions/AsyncLockDisposedException.cs	7
src/DotPulsar/Internal/Exceptions/AsyncQueueWithCursorDisposedException.cs	7
src/DotPulsar/Internal/Exceptions/UnexpectedResponseException.cs	9
src/DotPulsar/Internal/Exceptions/PulsarStreamDisposedException.cs	7
src/DotPulsar/Internal/Exceptions/AsyncQueueDisposedException.cs	7
src/DotPulsar/Internal/Exceptions/ConnectionDisposedException.cs	7
src/DotPulsar/Internal/Exceptions/AsyncQueueWithCursorNoItemException.cs	8
src/DotPulsar/Internal/ConsumerProcess.cs	66
src/DotPulsar/Internal/Extensions/MessageMetadataExtensions.cs	44
src/DotPulsar/Internal/Extensions/CommandExtensions.cs	166
src/DotPulsar/Internal/Extensions/ReadOnlySequenceExtensions.cs	70
src/DotPulsar/Internal/Extensions/MessageIdDataExtensions.cs	15
src/DotPulsar/Internal/Extensions/ActivityExtensions.cs	32
src/DotPulsar/Internal/Extensions/MessagePackageExtensions.cs	19
src/DotPulsar/Internal/Requests/ConnectRequest.cs	22
src/DotPulsar/Internal/Requests/SendRequest.cs	34
src/DotPulsar/Internal/Requests/StandardRequest.cs	44
src/DotPulsar/Internal/ReaderBuilder.cs	67
src/DotPulsar/Internal/AsyncQueueWithCursor.cs	222
src/DotPulsar/Internal/BatchHandler.cs	106
src/DotPulsar/Internal/MonitorState.cs	58
src/DotPulsar/Internal/TokenAuthentication.cs	18
src/DotPulsar/Internal/ConsumerChannel.cs	184
src/DotPulsar/Internal/ProducerBuilder.cs	93
src/DotPulsar/Internal/RequestId.cs	12
src/DotPulsar/Internal/ChunkingPipeline.cs	78
src/DotPulsar/Internal/ProducerProcess.cs	60
src/DotPulsar/Internal/EnumLookup.cs	20
src/DotPulsar/Internal/Compression/DecompressorFactory.cs	17
src/DotPulsar/Internal/Compression/ZstdSharpCompression.cs	130
src/DotPulsar/Internal/Compression/Decompressor.cs	19
src/DotPulsar/Internal/Compression/Lz4Compression.cs	147
src/DotPulsar/Internal/Compression/ZlibCompression.cs	83
src/DotPulsar/Internal/Compression/ZstdCompression.cs	115
src/DotPulsar/Internal/Compression/Compressor.cs	21
src/DotPulsar/Internal/Compression/CompressionFactories.cs	49
src/DotPulsar/Internal/Compression/SnappyCompression.cs	83
src/DotPulsar/Internal/Compression/CompressionTester.cs	17
src/DotPulsar/Internal/Compression/CompressorFactory.cs	17
src/DotPulsar/Internal/ConnectionPool.cs	211
src/DotPulsar/Internal/MessagePackage.cs	16
src/DotPulsar/Internal/Executor.cs	157
src/DotPulsar/Internal/FuncExceptionHandler.cs	13
src/DotPulsar/Internal/SubProducer.cs	207
src/DotPulsar/Internal/StateTask.cs	19
src/DotPulsar/Internal/Awaiter.cs	39
src/DotPulsar/Internal/ReaderProcess.cs	53
src/DotPulsar/Internal/StateTaskCollection.cs	69
src/DotPulsar/Internal/PulsarStream.cs	129
src/DotPulsar/Internal/Abstractions/IDecompress.cs	8
src/DotPulsar/Internal/Abstractions/IChannel.cs	17
src/DotPulsar/Internal/Abstractions/IExecute.cs	20
src/DotPulsar/Internal/Abstractions/IRequest.cs	10
src/DotPulsar/Internal/Abstractions/IStateChanged.cs	11
src/DotPulsar/Internal/Abstractions/IDequeue.cs	8
src/DotPulsar/Internal/Abstractions/ICompressorFactory.cs	8
src/DotPulsar/Internal/Abstractions/IEnqueue.cs	6
src/DotPulsar/Internal/Abstractions/IConsumerChannelFactory.cs	8
src/DotPulsar/Internal/Abstractions/IProducerChannelFactory.cs	8
src/DotPulsar/Internal/Abstractions/IProducerChannel.cs	12
src/DotPulsar/Internal/Abstractions/IRegisterEvent.cs	6
src/DotPulsar/Internal/Abstractions/IEvent.cs	7
src/DotPulsar/Internal/Abstractions/IStateManager.cs	7
src/DotPulsar/Internal/Abstractions/IConsumerChannel.cs	17
src/DotPulsar/Internal/Abstractions/IConnection.cs	27
src/DotPulsar/Internal/Abstractions/IPulsarStream.cs	12
src/DotPulsar/Internal/Abstractions/IMessageFactory.cs	9
src/DotPulsar/Internal/Abstractions/ICompress.cs	8
src/DotPulsar/Internal/Abstractions/IConnectionPool.cs	9
src/DotPulsar/Internal/Abstractions/IDecompressorFactory.cs	8
src/DotPulsar/Internal/Abstractions/IContainsChannel.cs	10
src/DotPulsar/Internal/Abstractions/IContainsProducerChannel.cs	7
src/DotPulsar/Internal/Abstractions/IProcess.cs	9
src/DotPulsar/Internal/Abstractions/Process.cs	92
src/DotPulsar/Internal/Connection.cs	259
src/DotPulsar/Internal/MessageFactory.cs	76
src/DotPulsar/Internal/PulsarClientBuilder.cs	142
src/DotPulsar/Internal/StateManager.cs	63
src/DotPulsar/Internal/Reader.cs	117
src/DotPulsar/Internal/ExecutionResult.cs	11
src/DotPulsar/Internal/Events/ProducerChannelConnected.cs	13
src/DotPulsar/Internal/Events/ChannelActivated.cs	10
src/DotPulsar/Internal/Events/ReaderCreated.cs	10
src/DotPulsar/Internal/Events/ProducerDisposed.cs	10
src/DotPulsar/Internal/Events/ChannelClosedByServer.cs	10
src/DotPulsar/Internal/Events/ProducerCreated.cs	10
src/DotPulsar/Internal/Events/ChannelDeactivated.cs	10
src/DotPulsar/Internal/Events/ChannelDisconnected.cs	10
src/DotPulsar/Internal/Events/ConsumerDisposed.cs	10
src/DotPulsar/Internal/Events/SendReceiptWrongOrdering.cs	9
src/DotPulsar/Internal/Events/ConsumerCreated.cs	10
src/DotPulsar/Internal/Events/ReaderDisposed.cs	10
src/DotPulsar/Internal/Events/ChannelConnected.cs	10
src/DotPulsar/Internal/Events/ChannelUnsubscribed.cs	10
src/DotPulsar/Internal/Events/ProducerWaitingForExclusive.cs	9
src/DotPulsar/Internal/Events/ExecutorFaulted.cs	13
src/DotPulsar/Internal/Events/ChannelReachedEndOfTopic.cs	10
src/DotPulsar/Internal/ConsumerChannelFactory.cs	46
src/DotPulsar/Internal/Consumer.cs	175
src/DotPulsar/Internal/CancelableCompletionSource.cs	36
src/DotPulsar/Internal/Connector.cs	109
src/DotPulsar/Internal/ProducerChannelFactory.cs	70
src/DotPulsar/Internal/AsyncQueue.cs	81
src/DotPulsar/Internal/DotPulsarActivitySource.cs	59
src/DotPulsar/Internal/Serializer.cs	49
src/DotPulsar/MessageId.cs	67
src/DotPulsar/ProducerAccessMode.cs	8
src/DotPulsar/RoundRobinPartitionRouter.cs	20
src/DotPulsar/Exceptions/FaultedException.cs	7
src/DotPulsar/Exceptions/PersistenceException.cs	5
src/DotPulsar/Exceptions/InvalidTopicNameException.cs	5
src/DotPulsar/Exceptions/TooManyRequestsException.cs	5
src/DotPulsar/Exceptions/ConfigurationException.cs	6
src/DotPulsar/Exceptions/ChecksumException.cs	5
src/DotPulsar/Exceptions/ReaderClosedException.cs	6
src/DotPulsar/Exceptions/IncompatibleSchemaException.cs	5
src/DotPulsar/Exceptions/NotAllowedException.cs	7
src/DotPulsar/Exceptions/AuthenticationException.cs	7
src/DotPulsar/Exceptions/ProducerClosedException.cs	6
src/DotPulsar/Exceptions/SubscriptionNotFoundException.cs	5
src/DotPulsar/Exceptions/ConsumerDisposedException.cs	7
src/DotPulsar/Exceptions/TransactionConflictException.cs	7
src/DotPulsar/Exceptions/MetadataException.cs	5
src/DotPulsar/Exceptions/ConsumerAssignException.cs	5
src/DotPulsar/Exceptions/InvalidTransactionStatusException.cs	7
src/DotPulsar/Exceptions/UnknownException.cs	6
src/DotPulsar/Exceptions/UnsupportedVersionException.cs	5
src/DotPulsar/Exceptions/ChannelNotReadyException.cs	6
src/DotPulsar/Exceptions/SchemaSerializationException.cs	6
src/DotPulsar/Exceptions/ConsumerNotFoundException.cs	5
src/DotPulsar/Exceptions/TopicNotFoundException.cs	5
src/DotPulsar/Exceptions/ReaderFaultedException.cs	7
src/DotPulsar/Exceptions/InvalidSchemeException.cs	6
src/DotPulsar/Exceptions/ProducerFaultedException.cs	7
src/DotPulsar/Exceptions/ConsumerBusyException.cs	5
src/DotPulsar/Exceptions/TransactionCoordinatorNotFoundException.cs	7
src/DotPulsar/Exceptions/TopicTerminatedException.cs	5
src/DotPulsar/Exceptions/ProducerBlockedQuotaExceededException.cs	5
src/DotPulsar/Exceptions/ConsumerFaultedException.cs	7
src/DotPulsar/Exceptions/PulsarClientDisposedException.cs	7
src/DotPulsar/Exceptions/ReaderDisposedException.cs	7
src/DotPulsar/Exceptions/ProducerFencedException.cs	5
src/DotPulsar/Exceptions/ProducerBusyException.cs	5
src/DotPulsar/Exceptions/ConsumerClosedException.cs	6
src/DotPulsar/Exceptions/ServiceNotReadyException.cs	5
src/DotPulsar/Exceptions/ConnectionSecurityException.cs	6
src/DotPulsar/Exceptions/DotPulsarException.cs	8
src/DotPulsar/Exceptions/ProducerDisposedException.cs	7
src/DotPulsar/Exceptions/AuthorizationException.cs	5
src/DotPulsar/Exceptions/PulsarClientClosedException.cs	6
src/DotPulsar/Exceptions/CompressionException.cs	6
src/DotPulsar/SinglePartitionRouter.cs	26
src/DotPulsar/Schemas/ByteArraySchema.cs	16
src/DotPulsar/Schemas/TimeSchema.cs	25
src/DotPulsar/Schemas/FloatSchema .cs	30
src/DotPulsar/Schemas/TimestampSchema.cs	36
src/DotPulsar/Schemas/BooleanSchema.cs	28
src/DotPulsar/Schemas/IntegerSchema.cs	30
src/DotPulsar/Schemas/LongSchema.cs	30
src/DotPulsar/Schemas/ByteSchema.cs	21
src/DotPulsar/Schemas/ShortSchema.cs	30
src/DotPulsar/Schemas/StringSchema.cs	67
src/DotPulsar/Schemas/DoubleSchema.cs	30
src/DotPulsar/Schemas/ByteSequenceSchema.cs	16
src/DotPulsar/Extensions/SendChannelExtensions.cs	29
src/DotPulsar/Extensions/MessageMetadataExtensions.cs	10
src/DotPulsar/Extensions/SendExtensions.cs	31
src/DotPulsar/Extensions/SeekExtensions.cs	13
src/DotPulsar/Extensions/MessageBuilderExtensions.cs	14
src/DotPulsar/Extensions/MessageExtensions.cs	13
src/DotPulsar/Extensions/ConsumerBuilderExtensions.cs	34
src/DotPulsar/Extensions/ReceiveExtensions.cs	14
src/DotPulsar/Extensions/ConsumerExtensions.cs	47
src/DotPulsar/Extensions/ReaderBuilderExtensions.cs	34
src/DotPulsar/Extensions/ReaderExtensions.cs	28
src/DotPulsar/Extensions/PulsarClientBuilderExtensions.cs	19
src/DotPulsar/Extensions/ProducerExtensions.cs	31
src/DotPulsar/Extensions/ProducerBuilderExtensions.cs	34
src/DotPulsar/Extensions/StateExtensions.cs	136
src/DotPulsar/Extensions/PulsarClientExtensions.cs	20
src/DotPulsar/SubscriptionType.cs	9
src/DotPulsar/ProcessingOptions.cs	61
src/DotPulsar/AuthenticationFactory.cs	12
src/DotPulsar/ReaderState.cs	10
src/DotPulsar/ConsumerState.cs	12
src/DotPulsar/ProducerState.cs	12
src/DotPulsar/SchemaInfo.cs	32
src/DotPulsar/Schema.cs	33
src/DotPulsar/FaultAction.cs	8
src/DotPulsar/Abstractions/ISeek.cs	9
src/DotPulsar/Abstractions/IPulsarClientBuilder.cs	22
src/DotPulsar/Abstractions/IMessage.cs	28
src/DotPulsar/Abstractions/IHandleStateChanged.cs	9
src/DotPulsar/Abstractions/IMessageRouter.cs	6
src/DotPulsar/Abstractions/IMessageBuilder.cs	21
src/DotPulsar/Abstractions/IMessageOfT.cs	6
src/DotPulsar/Abstractions/IProducer.cs	8
src/DotPulsar/Abstractions/IState.cs	11
src/DotPulsar/Abstractions/IConsumerBuilder.cs	16
src/DotPulsar/Abstractions/IReceive.cs	8
src/DotPulsar/Abstractions/IPulsarClient.cs	10
src/DotPulsar/Abstractions/IAuthentication.cs	9
src/DotPulsar/Abstractions/IGetLastMessageId.cs	8
src/DotPulsar/Abstractions/ISchema.cs	9
src/DotPulsar/Abstractions/IConsumerOfT.cs	3
src/DotPulsar/Abstractions/IConsumer.cs	17
src/DotPulsar/Abstractions/IReaderBuilder.cs	12
src/DotPulsar/Abstractions/IProducerBuilder.cs	15
src/DotPulsar/Abstractions/ISendChannel.cs	10
src/DotPulsar/Abstractions/ISend.cs	8
src/DotPulsar/Abstractions/IProducerOfT.cs	6
src/DotPulsar/Abstractions/IReaderOfT.cs	3
src/DotPulsar/Abstractions/IReader.cs	8
src/DotPulsar/Abstractions/IHandleException.cs	7
src/DotPulsar/ConsumerOptions.cs	37
src/DotPulsar/ProducerStateChanged.cs	13
src/DotPulsar/PulsarClient.cs	130