This is an automated email from the ASF dual-hosted git repository.
blankensteiner pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-dotpulsar.git.
from c18b504 moved haproxy.cfg
new 8f7e7b4 added editorconfig, resharper/rider dotsettings file and
idea/rider code style required files
new ef4ea32 first full cleanup
new 2b79e9e removed warnings and improved some code contructs with newer
versions. removed some awaits. interpolated all strings.
new ba46dd9 found mini optimization on connector.
new a24b31f More small tweaks.
new f316f0a reverted some auto changes as suggested. fixed awaitor name
to awaiter. more new and advanced contrucsts like switch expressions, ternary
operations and coalesce operators. adjusted some rules to not get executed.
new f1097ec code review change requests
new ce6b221 missing tasks forwarding.
new f7639e6 code review change requests fixed style rules accordingly
new 87b0d8e code review change requests
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.editorconfig | 29 +++++
.idea/.idea.DotPulsar/.idea/codeStyles/Project.xml | 8 ++
.../.idea/codeStyles/codeStyleConfig.xml | 5 +
DotPulsar.sln.DotSettings | 64 ++++++++++
samples/Consuming/Program.cs | 27 ++--
samples/Producing/Program.cs | 34 +++--
samples/Reading/Program.cs | 30 ++---
src/DotPulsar/Abstractions/IConsumer.cs | 10 +-
src/DotPulsar/Abstractions/IHandleException.cs | 4 +-
src/DotPulsar/Abstractions/IMessageBuilder.cs | 8 +-
src/DotPulsar/Abstractions/IProducer.cs | 10 +-
src/DotPulsar/Abstractions/IPulsarClient.cs | 4 +-
src/DotPulsar/Abstractions/IPulsarClientBuilder.cs | 8 +-
src/DotPulsar/Abstractions/IReader.cs | 8 +-
src/DotPulsar/Abstractions/IStateChanged.cs | 6 +-
src/DotPulsar/ExceptionContext.cs | 6 +-
.../Exceptions/AuthenticationException.cs | 4 +-
src/DotPulsar/Exceptions/ConsumerBusyException.cs | 2 +-
.../Exceptions/ConsumerDisposedException.cs | 8 +-
src/DotPulsar/Exceptions/DotPulsarException.cs | 4 +-
src/DotPulsar/Exceptions/ProducerBusyException.cs | 2 +-
.../Exceptions/ProducerDisposedException.cs | 8 +-
.../Exceptions/PulsarClientDisposedException.cs | 6 +-
.../Exceptions/ReaderDisposedException.cs | 8 +-
src/DotPulsar/Extensions/ProducerExtensions.cs | 9 +-
src/DotPulsar/Extensions/PulsarClientExtensions.cs | 17 ++-
src/DotPulsar/Internal/Abstractions/IConnection.cs | 10 +-
.../Internal/Abstractions/IConnectionPool.cs | 8 +-
.../Internal/Abstractions/IConsumerChannel.cs | 10 +-
.../Abstractions/IConsumerChannelFactory.cs | 6 +-
src/DotPulsar/Internal/Abstractions/IDequeue.cs | 6 +-
src/DotPulsar/Internal/Abstractions/IExecute.cs | 8 +-
src/DotPulsar/Internal/Abstractions/IProcess.cs | 6 +-
.../Internal/Abstractions/IProducerChannel.cs | 16 +--
.../Abstractions/IProducerChannelFactory.cs | 6 +-
.../Internal/Abstractions/IPulsarStream.cs | 12 +-
.../Internal/Abstractions/IReaderChannel.cs | 8 +-
.../Internal/Abstractions/IReaderChannelFactory.cs | 6 +-
.../Internal/Abstractions/IStateManager.cs | 4 +-
src/DotPulsar/Internal/AsyncLock.cs | 25 ++--
src/DotPulsar/Internal/AsyncLockExecutor.cs | 13 +-
src/DotPulsar/Internal/AsyncQueue.cs | 19 +--
src/DotPulsar/Internal/{Awaitor.cs => Awaiter.cs} | 23 ++--
src/DotPulsar/Internal/BatchHandler.cs | 25 ++--
.../Internal/CancelableCompletionSource.cs | 20 +--
src/DotPulsar/Internal/Channel.cs | 39 ++++--
src/DotPulsar/Internal/ChannelManager.cs | 55 ++++----
src/DotPulsar/Internal/Connection.cs | 65 +++++-----
src/DotPulsar/Internal/ConnectionPool.cs | 14 ++-
src/DotPulsar/Internal/Connector.cs | 33 +++--
src/DotPulsar/Internal/Constants.cs | 6 +-
src/DotPulsar/Internal/Consumer.cs | 42 ++++---
src/DotPulsar/Internal/ConsumerBuilder.cs | 6 +-
src/DotPulsar/Internal/ConsumerChannel.cs | 34 ++---
src/DotPulsar/Internal/ConsumerChannelFactory.cs | 17 +--
src/DotPulsar/Internal/ConsumerProcess.cs | 10 +-
src/DotPulsar/Internal/Crc32C.cs | 18 +--
src/DotPulsar/Internal/DefaultExceptionHandler.cs | 63 +++++-----
src/DotPulsar/Internal/DotPulsarEventSource.cs | 17 ++-
src/DotPulsar/Internal/Events/ChannelActivated.cs | 9 +-
.../Internal/Events/ChannelClosedByServer.cs | 9 +-
src/DotPulsar/Internal/Events/ChannelConnected.cs | 9 +-
.../Internal/Events/ChannelDeactivated.cs | 9 +-
.../Internal/Events/ChannelDisconnected.cs | 9 +-
.../Internal/Events/ChannelReachedEndOfTopic.cs | 9 +-
.../Internal/Events/ChannelUnsubscribed.cs | 9 +-
src/DotPulsar/Internal/Events/ConsumerCreated.cs | 6 +-
src/DotPulsar/Internal/Events/ConsumerDisposed.cs | 6 +-
src/DotPulsar/Internal/Events/ExecutorFaulted.cs | 9 +-
src/DotPulsar/Internal/Events/ProducerCreated.cs | 6 +-
src/DotPulsar/Internal/Events/ProducerDisposed.cs | 6 +-
src/DotPulsar/Internal/Events/ReaderCreated.cs | 6 +-
src/DotPulsar/Internal/Events/ReaderDisposed.cs | 6 +-
src/DotPulsar/Internal/ExceptionHandlerPipeline.cs | 14 ++-
.../Exceptions/AsyncLockDisposedException.cs | 16 ++-
.../Exceptions/AsyncQueueDisposedException.cs | 16 ++-
.../Exceptions/ChannelNotReadyException.cs | 4 +-
.../Exceptions/ConnectionDisposedException.cs | 16 ++-
.../Exceptions/ConsumerNotFoundException.cs | 4 +-
.../Exceptions/PulsarStreamDisposedException.cs | 16 ++-
.../Exceptions/ServiceNotReadyException.cs | 4 +-
.../Exceptions/TooManyRequestsException.cs | 4 +-
.../Exceptions/UnexpectedResponseException.cs | 7 +-
src/DotPulsar/Internal/Executor.cs | 45 ++++---
.../Internal/Extensions/CommandExtensions.cs | 138 ++++++++-------------
.../Extensions/MessageMetadataExtensions.cs | 10 +-
.../Extensions/MessagePackageExtensions.cs | 9 +-
.../Extensions/ReadOnlySequenceExtensions.cs | 14 ++-
src/DotPulsar/Internal/FuncExceptionHandler.cs | 16 +--
src/DotPulsar/Internal/IdLookup.cs | 20 +--
src/DotPulsar/Internal/MessageBuilder.cs | 12 +-
src/DotPulsar/Internal/MessagePackage.cs | 8 +-
src/DotPulsar/Internal/NotReadyChannel.cs | 44 ++++---
src/DotPulsar/Internal/Process.cs | 10 +-
src/DotPulsar/Internal/ProcessManager.cs | 29 +++--
src/DotPulsar/Internal/Producer.cs | 50 ++++----
src/DotPulsar/Internal/ProducerBuilder.cs | 6 +-
src/DotPulsar/Internal/ProducerChannel.cs | 44 +++----
src/DotPulsar/Internal/ProducerChannelFactory.cs | 13 +-
src/DotPulsar/Internal/ProducerProcess.cs | 8 +-
src/DotPulsar/Internal/PulsarClientBuilder.cs | 45 ++++---
src/DotPulsar/Internal/PulsarStream.cs | 35 +++---
src/DotPulsar/Internal/Reader.cs | 28 ++---
src/DotPulsar/Internal/ReaderBuilder.cs | 6 +-
src/DotPulsar/Internal/ReaderChannelFactory.cs | 15 +--
src/DotPulsar/Internal/ReaderProcess.cs | 10 +-
src/DotPulsar/Internal/RequestResponseHandler.cs | 60 ++++-----
src/DotPulsar/Internal/SendPackage.cs | 10 +-
src/DotPulsar/Internal/SequenceBuilder.cs | 22 ++--
src/DotPulsar/Internal/SequenceId.cs | 4 +-
src/DotPulsar/Internal/Serializer.cs | 33 ++---
src/DotPulsar/Internal/StateManager.cs | 11 +-
src/DotPulsar/Internal/StateTask.cs | 14 +--
src/DotPulsar/Internal/StateTaskCollection.cs | 45 ++++---
src/DotPulsar/Internal/SubscribeResponse.cs | 3 +-
src/DotPulsar/Internal/UIntUnion.cs | 7 +-
src/DotPulsar/Message.cs | 20 +--
src/DotPulsar/MessageId.cs | 34 +++--
src/DotPulsar/MessageMetadata.cs | 34 ++---
src/DotPulsar/PulsarClient.cs | 23 ++--
tests/DotPulsar.StressTests/ConnectionTests.cs | 23 ++--
tests/DotPulsar.StressTests/ConsumerTests.cs | 30 ++---
.../EnumerableTaskExtensions.cs | 25 ++--
.../Fixtures/StandaloneClusterFixture.cs | 18 ++-
.../Fixtures/StandaloneClusterTests.cs | 9 +-
.../DotPulsar.StressTests/XunitExceptionHandler.cs | 16 ++-
tests/DotPulsar.Tests/Internal/AsyncLockTests.cs | 13 +-
tests/DotPulsar.Tests/Internal/AsyncQueueTests.cs | 10 +-
tests/DotPulsar.Tests/Internal/Crc32CTests.cs | 17 ++-
.../Extensions/ReadOnlySequenceExtensionsTests.cs | 8 +-
.../Internal/SequenceBuilderTests.cs | 16 ++-
tests/DotPulsar.Tests/Internal/SerializerTests.cs | 7 +-
.../DotPulsar.Tests/Internal/StateManagerTests.cs | 10 +-
133 files changed, 1292 insertions(+), 1033 deletions(-)
create mode 100644 .editorconfig
create mode 100644 .idea/.idea.DotPulsar/.idea/codeStyles/Project.xml
create mode 100644 .idea/.idea.DotPulsar/.idea/codeStyles/codeStyleConfig.xml
create mode 100644 DotPulsar.sln.DotSettings
rename src/DotPulsar/Internal/{Awaitor.cs => Awaiter.cs} (67%)
