Docs examples update

tests/NATS.Net.DocsExamples/.editorconfig

@@ -0,0 +1,4 @@
+[*.cs]
+csharp_style_var_for_built_in_types = false:warning
+csharp_style_var_when_type_is_apparent = false:warning
+csharp_style_var_elsewhere = false:warning

tests/NATS.Net.DocsExamples/Advanced/IntroPage.cs

@@ -22,15 +22,15 @@ public async Task Run()
 
         {
             #region lowlevel-sub
-            await using var nc = new NatsConnection();
+            await using NatsConnection nc = new NatsConnection();
 
             // Connections are lazy, so we need to connect explicitly
             // to avoid any races between subscription and publishing.
             await nc.ConnectAsync();
 
-            await using var sub = await nc.SubscribeCoreAsync<int>("foo");
+            await using INatsSub<int> sub = await nc.SubscribeCoreAsync<int>("foo");
 
-            for (var i = 0; i < 10; i++)
+            for (int i = 0; i < 10; i++)
             {
                 Console.WriteLine($" Publishing {i}...");
                 await nc.PublishAsync<int>("foo", i);
@@ -41,7 +41,7 @@ public async Task Run()
 
             // Messages have been collected in the subscription internal channel
             // now we can drain them
-            await foreach (var msg in sub.Msgs.ReadAllAsync())
+            await foreach (NatsMsg<int> msg in sub.Msgs.ReadAllAsync())
             {
                 Console.WriteLine($"Received {msg.Subject}: {msg.Data}\n");
                 if (msg.Data == -1)
@@ -56,7 +56,7 @@ public async Task Run()
 
         {
             #region ping
-            await using var nc = new NatsClient();
+            await using NatsClient nc = new NatsClient();
 
             TimeSpan rtt = await nc.PingAsync();
 
@@ -66,18 +66,18 @@ public async Task Run()
 
         {
             #region logging
-            using var loggerFactory = LoggerFactory.Create(configure: builder => builder.AddConsole());
+            using ILoggerFactory loggerFactory = LoggerFactory.Create(configure: builder => builder.AddConsole());
 
-            var opts = new NatsOpts { LoggerFactory = loggerFactory };
+            NatsOpts opts = new NatsOpts { LoggerFactory = loggerFactory };
 
-            await using var nc = new NatsClient(opts);
+            await using NatsClient nc = new NatsClient(opts);
             #endregion
         }
 
         {
             #region opts
 
-            var opts = new NatsOpts
+            NatsOpts opts = new NatsOpts
             {
                 // You need to set pending in the constructor and not use
                 // the option here, as it will be ignored.
@@ -89,19 +89,19 @@ public async Task Run()
                 // ...
             };
 
-            await using var nc = new NatsClient(opts, pending: BoundedChannelFullMode.DropNewest);
+            await using NatsClient nc = new NatsClient(opts, pending: BoundedChannelFullMode.DropNewest);
             #endregion
         }
 
         {
             #region opts2
 
-            var opts = new NatsOpts
+            NatsOpts opts = new NatsOpts
             {
                 // Your custom options
             };
 
-            await using var nc = new NatsConnection(opts);
+            await using NatsConnection nc = new NatsConnection(opts);
             #endregion
         }
     }

tests/NATS.Net.DocsExamples/Advanced/SecurityPage.cs

@@ -15,7 +15,7 @@ public async Task Run()
 
         {
             #region user-pass
-            var opts = new NatsOpts
+            NatsOpts opts = new NatsOpts
             {
                 AuthOpts = NatsAuthOpts.Default with
                 {
@@ -24,27 +24,27 @@ public async Task Run()
                 },
             };
 
-            await using var nats = new NatsClient(opts);
+            await using NatsClient nats = new NatsClient(opts);
             #endregion
         }
 
         {
             #region tls-implicit
-            var opts = new NatsOpts
+            NatsOpts opts = new NatsOpts
             {
                 TlsOpts = new NatsTlsOpts
                 {
                     Mode = TlsMode.Implicit,
                 },
             };
 
-            await using var nats = new NatsClient(opts);
+            await using NatsClient nats = new NatsClient(opts);
             #endregion
         }
 
         {
             #region tls-mutual
-            var opts = new NatsOpts
+            NatsOpts opts = new NatsOpts
             {
                 TlsOpts = new NatsTlsOpts
                 {
@@ -54,7 +54,7 @@ public async Task Run()
                 },
             };
 
-            await using var nats = new NatsClient(opts);
+            await using NatsClient nats = new NatsClient(opts);
             #endregion
         }
     }

tests/NATS.Net.DocsExamples/Advanced/SerializationPage.cs

@@ -31,9 +31,9 @@ public async Task Run()
 
             #region default
             // Set your custom serializer registry as the default for the connection.
-            var opts = NatsOpts.Default with { SerializerRegistry = new MyProtoBufSerializerRegistry() };
+            NatsOpts opts = NatsOpts.Default with { SerializerRegistry = new MyProtoBufSerializerRegistry() };
 
-            await using var nc = new NatsClient(opts);
+            await using NatsClient nc = new NatsClient(opts);
             #endregion
         }
 
@@ -42,15 +42,15 @@ public async Task Run()
 
             #region my-data-usage
             // Set the custom serializer registry as the default for the connection.
-            var myRegistry = new NatsJsonContextSerializerRegistry(MyJsonContext.Default, OtherJsonContext.Default);
+            NatsJsonContextSerializerRegistry myRegistry = new NatsJsonContextSerializerRegistry(MyJsonContext.Default, OtherJsonContext.Default);
 
-            var opts = new NatsOpts { SerializerRegistry = myRegistry };
+            NatsOpts opts = new NatsOpts { SerializerRegistry = myRegistry };
 
-            await using var nc = new NatsClient(opts);
+            await using NatsClient nc = new NatsClient(opts);
 
-            var subscriber = Task.Run(async () =>
+            Task subscriber = Task.Run(async () =>
             {
-                await foreach (var msg in nc.SubscribeAsync<MyData>("foo"))
+                await foreach (NatsMsg<MyData> msg in nc.SubscribeAsync<MyData>("foo"))
                 {
                     // Outputs 'MyData { Id = 1, Name = bar }'
                     Console.WriteLine(msg.Data);
@@ -71,13 +71,13 @@ public async Task Run()
             Console.WriteLine("  #region my-data-publish");
 
             #region my-data-publish
-            await using var nc = new NatsClient();
+            await using NatsClient nc = new NatsClient();
 
-            var serializer = new NatsJsonContextSerializer<MyData>(MyJsonContext.Default);
+            NatsJsonContextSerializer<MyData> serializer = new NatsJsonContextSerializer<MyData>(MyJsonContext.Default);
 
-            var subscriber = Task.Run(async () =>
+            Task subscriber = Task.Run(async () =>
             {
-                await foreach (var msg in nc.SubscribeAsync<MyData>("foo", serializer: serializer))
+                await foreach (NatsMsg<MyData> msg in nc.SubscribeAsync<MyData>("foo", serializer: serializer))
                 {
                     // Outputs 'MyData { Id = 1, Name = bar }'
                     Console.WriteLine(msg.Data);
@@ -98,13 +98,13 @@ public async Task Run()
             Console.WriteLine("  #region custom");
 
             #region custom
-            var opts = new NatsOpts { SerializerRegistry = new MyProtoBufSerializerRegistry() };
+            NatsOpts opts = new NatsOpts { SerializerRegistry = new MyProtoBufSerializerRegistry() };
 
-            await using var nc = new NatsClient(opts);
+            await using NatsClient nc = new NatsClient(opts);
 
-            var subscriber = Task.Run(async () =>
+            Task subscriber = Task.Run(async () =>
             {
-                await foreach (var msg in nc.SubscribeAsync<Greeting>("foo"))
+                await foreach (NatsMsg<Greeting> msg in nc.SubscribeAsync<Greeting>("foo"))
                 {
                     // Outputs '{ "id": 42, "name": "Marvin" }'
                     Console.WriteLine(msg.Data);
@@ -125,23 +125,23 @@ public async Task Run()
             Console.WriteLine("  #region chain");
 
             #region chain
-            var opts = new NatsOpts { SerializerRegistry = new MixedSerializerRegistry() };
+            NatsOpts opts = new NatsOpts { SerializerRegistry = new MixedSerializerRegistry() };
 
-            await using var nc = new NatsClient(opts);
+            await using NatsClient nc = new NatsClient(opts);
 
-            var subscriber1 = Task.Run(async () =>
+            Task subscriber1 = Task.Run(async () =>
             {
-                await foreach (var msg in nc.SubscribeAsync<Greeting>("greet"))
+                await foreach (NatsMsg<Greeting> msg in nc.SubscribeAsync<Greeting>("greet"))
                 {
                     // Outputs '{ "id": 42, "name": "Marvin" }'
                     Console.WriteLine(msg.Data);
                     break;
                 }
             });
 
-            var subscriber2 = Task.Run(async () =>
+            Task subscriber2 = Task.Run(async () =>
             {
-                await foreach (var msg in nc.SubscribeAsync<MyData>("data"))
+                await foreach (NatsMsg<MyData> msg in nc.SubscribeAsync<MyData>("data"))
                 {
                     // Outputs 'MyData { Id = 1, Name = bar }'
                     Console.WriteLine(msg.Data);
@@ -166,19 +166,19 @@ public async Task Run()
             #region buffers
             // The default serializer knows how to deal with binary data types like NatsMemoryOwner<byte>.
             // So, you can use it without specifying a serializer.
-            await using var nc = new NatsClient();
+            await using NatsClient nc = new NatsClient();
 
-            var subscriber = Task.Run(async () =>
+            Task subscriber = Task.Run(async () =>
             {
                 // The default serializer knows how to deal with binary data types like NatsMemoryOwner<byte>.
-                await foreach (var msg in nc.SubscribeAsync<NatsMemoryOwner<byte>>("foo"))
+                await foreach (NatsMsg<NatsMemoryOwner<byte>> msg in nc.SubscribeAsync<NatsMemoryOwner<byte>>("foo"))
                 {
                     // Check for the end of messages.
                     if (msg.Data.Length == 0)
                         break;
 
                     // Dispose the memory owner after using it so it can be returned to the pool.
-                    using var memoryOwner = msg.Data;
+                    using NatsMemoryOwner<byte> memoryOwner = msg.Data;
 
                     // Outputs 'Hi'
                     Console.WriteLine(Encoding.ASCII.GetString(memoryOwner.Memory.Span));
@@ -190,8 +190,8 @@ public async Task Run()
 
             // Don't reuse NatsBufferWriter, it's disposed and returned to the pool
             // by the publisher after being written to the network.
-            var bw = new NatsBufferWriter<byte>();
-            var memory = bw.GetMemory(2);
+            NatsBufferWriter<byte> bw = new NatsBufferWriter<byte>();
+            Memory<byte> memory = bw.GetMemory(2);
             memory.Span[0] = (byte)'H';
             memory.Span[1] = (byte)'i';
             bw.Advance(2);

tests/NATS.Net.DocsExamples/Core/IntroPage.cs

@@ -2,9 +2,7 @@
 #pragma warning disable SA1124
 #pragma warning disable SA1509
 
-using Microsoft.Extensions.Logging;
 using NATS.Client.Core;
-using NATS.Client.Serializers.Json;
 
 namespace NATS.Net.DocsExamples.Core;
 
@@ -20,9 +18,9 @@ public async Task Run()
             subscription = Task.Run(async () =>
             {
                 #region sub
-                await using var nc = new NatsClient();
+                await using NatsClient nc = new NatsClient();
 
-                await foreach (var msg in nc.SubscribeAsync<Bar>("bar.>"))
+                await foreach (NatsMsg<Bar> msg in nc.SubscribeAsync<Bar>("bar.>"))
                 {
                     if (msg.Subject == "bar.exit")
                         break;
@@ -37,9 +35,9 @@ public async Task Run()
 
         {
             #region pub
-            await using var nc = new NatsClient();
+            await using NatsClient nc = new NatsClient();
 
-            for (var i = 0; i < 10; i++)
+            for (int i = 0; i < 10; i++)
             {
                 Console.WriteLine($" Publishing {i}...");
                 await nc.PublishAsync<Bar>($"bar.baz.{i}", new Bar(Id: i, Name: "Baz"));
@@ -48,7 +46,7 @@ public async Task Run()
             await nc.PublishAsync("bar.exit");
             #endregion
 
-            for (var i = 0; i < 3; i++)
+            for (int i = 0; i < 3; i++)
             {
                 await Task.Delay(250);
                 await nc.PublishAsync("bar.exit");

tests/NATS.Net.DocsExamples/Core/PubSubPage.cs

@@ -16,11 +16,11 @@ public async Task Run()
 
         {
             #region pubsub
-            await using var nc = new NatsClient();
+            await using NatsClient nc = new NatsClient();
 
-            var subscription = Task.Run(async () =>
+            Task subscription = Task.Run(async () =>
             {
-                await foreach (var msg in nc.SubscribeAsync<int>("foo"))
+                await foreach (NatsMsg<int> msg in nc.SubscribeAsync<int>("foo"))
                 {
                     Console.WriteLine($"Received {msg.Subject}: {msg.Data}\n");
 
@@ -32,7 +32,7 @@ public async Task Run()
             // Give subscription time to start
             await Task.Delay(1000);
 
-            for (var i = 0; i < 10; i++)
+            for (int i = 0; i < 10; i++)
             {
                 Console.WriteLine($" Publishing {i}...");
                 await nc.PublishAsync<int>("foo", i);

tests/NATS.Net.DocsExamples/Core/QueuePage.cs

@@ -19,22 +19,22 @@ public async Task Run()
         Console.WriteLine("NATS.Net.DocsExamples.Core.QueuePage");
 
         #region queue
-        await using var nc = new NatsClient();
+        await using NatsClient nc = new NatsClient();
 
         // Create a cancellation token source to stop the subscriptions
-        using var cts = new CancellationTokenSource();
+        using CancellationTokenSource cts = new CancellationTokenSource();
 
-        var replyTasks = new List<Task>();
+        List<Task> replyTasks = new List<Task>();
 
-        for (var i = 0; i < 3; i++)
+        for (int i = 0; i < 3; i++)
         {
             // Create three subscriptions all on the same queue group
             // Create a background message loop for every subscription
-            var replyTaskId = i;
+            int replyTaskId = i;
             replyTasks.Add(Task.Run(async () =>
             {
                 // Retrieve messages until unsubscribed
-                await foreach (var msg in nc.SubscribeAsync<int>("math.double", queueGroup: "maths-service", cancellationToken: cts.Token))
+                await foreach (NatsMsg<int> msg in nc.SubscribeAsync<int>("math.double", queueGroup: "maths-service", cancellationToken: cts.Token))
                 {
                     Console.WriteLine($"[{replyTaskId}] Received request: {msg.Data}");
                     await msg.ReplyAsync($"Answer is: {2 * msg.Data}");
@@ -48,7 +48,7 @@ public async Task Run()
         await Task.Delay(1000);
 
         // Send a few requests
-        for (var i = 0; i < 10; i++)
+        for (int i = 0; i < 10; i++)
         {
             NatsMsg<string> reply = await nc.RequestAsync<int, string>("math.double", i);
             Console.WriteLine($"Reply: '{reply.Data}'");