Add benchmarks

sandbox/MicroBenchmark/JSPublishBench.cs

@@ -15,13 +15,16 @@ public class JSPublishBench
     private NatsConnection _nats;
     private NatsJSContext _js;
 
+    [Params(NatsRequestReplyMode.Direct, NatsRequestReplyMode.SharedInbox)]
+    public NatsRequestReplyMode Mode { get; set; }
+
     [Params(1, 10, 1_000)]
     public int Batch { get; set; }
 
     [GlobalSetup]
     public async Task Setup()
     {
-        _nats = new NatsConnection();
+        _nats = new NatsConnection(new NatsOpts { RequestReplyMode = Mode });
         _js = new NatsJSContext(_nats);
         await _nats.ConnectAsync();
         await _js.CreateStreamAsync(new StreamConfig("bench_test1", ["bench_test1"]));

sandbox/MicroBenchmark/KVBench.cs

@@ -16,10 +16,13 @@ public class KvBench
     private NatsKVContext _kv;
     private NatsKVStore _store;
 
+    [Params(NatsRequestReplyMode.Direct, NatsRequestReplyMode.SharedInbox)]
+    public NatsRequestReplyMode Mode { get; set; }
+
     [GlobalSetup]
     public async Task SetupAsync()
     {
-        _nats = new NatsConnection();
+        _nats = new NatsConnection(new NatsOpts { RequestReplyMode = Mode });
         _js = new NatsJSContext(_nats);
         _kv = new NatsKVContext(_js);
         _store = (NatsKVStore)(await _kv.CreateStoreAsync("benchmark"));

tests/NATS.Client.JetStream.Tests/ConsumerFetchTest.cs

@@ -112,7 +112,7 @@ public async Task Fetch_dispose_test(NatsRequestReplyMode mode)
         var signal2 = new WaitSignal();
         var reader = Task.Run(async () =>
         {
-            int x = 0;
+            var x = 0;
             await foreach (var msg in fc.Msgs.ReadAllAsync(cts.Token))
             {
                 _output.WriteLine($"rcv:{++x}");