Add PubManyAsync (#72)

src/main/MyNatsClient/INatsClient.cs

@@ -137,6 +137,14 @@ public interface INatsClient
         /// <param name="p"></param>
         void PubMany(Action<IPublisher> p);
 
+        /// <summary>
+        /// Gives access to a publisher that will be running in
+        /// an async locked scope until your injected delegate
+        /// is done.
+        /// </summary>
+        /// <param name="p"></param>
+        Task PubManyAsync(Func<IPublisher, Task> p);
+
         /// <summary>
         /// Async request response.
         /// </summary>
@@ -249,4 +257,4 @@ public interface INatsClient
         /// <param name="subscriptionInfo"></param>
         Task UnsubAsync(SubscriptionInfo subscriptionInfo);
     }
-}
+}

src/main/MyNatsClient/NatsClient.cs

@@ -467,6 +467,20 @@ public void PubMany(Action<IPublisher> p)
             });
         }
 
+        public async Task PubManyAsync(Func<IPublisher, Task> p)
+        {
+            ThrowIfDisposed();
+
+            ThrowIfNotConnected();
+
+            await _connection.WithWriteLockAsync(async writer =>
+            {
+                await p(new Publisher(writer, _connection.ServerInfo.MaxPayload)).ConfigureAwait(false);
+                if (ShouldAutoFlush)
+                    await writer.FlushAsync().ConfigureAwait(false);
+            }).ConfigureAwait(false);
+        }
+
         public Task<MsgOp> RequestAsync(string subject, string body, CancellationToken cancellationToken = default)
             => RequestAsync(subject, NatsEncoder.GetBytes(body), cancellationToken);
 

src/testing/IntegrationTests/PubSubTests.cs

@@ -99,10 +99,14 @@ public async Task Client_Should_be_able_to_publish_and_consume_messages_When_pub
 
             await Context.DelayAsync();
 
-            _client1.PubMany(async p =>
+            _client1.PubMany(p =>
             {
                 p.Pub(subject, messages[0]);
                 p.Pub(subject, Encoding.UTF8.GetBytes(messages[1]));
+            });
+
+            await _client1.PubManyAsync(async p =>
+            {
                 await p.PubAsync(subject, messages[2]);
                 await p.PubAsync(subject, Encoding.UTF8.GetBytes(messages[3]));
             });