This is an automated email from the ASF dual-hosted git repository.

blankensteiner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-dotpulsar.git

commit ce6b22119eaa49e726e6ba36f4913b55242f4170
Author: Sérgio Silveira <[email protected]>
AuthorDate: Tue Mar 31 16:23:18 2020 +0200

    missing tasks forwarding.
---
 src/DotPulsar/Internal/Connection.cs | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/src/DotPulsar/Internal/Connection.cs 
b/src/DotPulsar/Internal/Connection.cs
index ae4e470..6d2eb01 100644
--- a/src/DotPulsar/Internal/Connection.cs
+++ b/src/DotPulsar/Internal/Connection.cs
@@ -115,17 +115,17 @@ namespace DotPulsar.Internal
             return await responseTask.ConfigureAwait(false);
         }
 
-        public async Task<BaseCommand> Send(CommandConnect command, 
CancellationToken cancellationToken)
-            => await SendRequestResponse(command.AsBaseCommand(), 
cancellationToken).ConfigureAwait(false);
+        public Task<BaseCommand> Send(CommandConnect command, 
CancellationToken cancellationToken)
+            => SendRequestResponse(command.AsBaseCommand(), cancellationToken);
 
-        public async Task<BaseCommand> Send(CommandLookupTopic command, 
CancellationToken cancellationToken)
-            => await SendRequestResponse(command.AsBaseCommand(), 
cancellationToken).ConfigureAwait(false);
+        public Task<BaseCommand> Send(CommandLookupTopic command, 
CancellationToken cancellationToken)
+            => SendRequestResponse(command.AsBaseCommand(), cancellationToken);
 
-        public async Task<BaseCommand> Send(CommandSeek command, 
CancellationToken cancellationToken)
-            => await SendRequestResponse(command.AsBaseCommand(), 
cancellationToken).ConfigureAwait(false);
+        public Task<BaseCommand> Send(CommandSeek command, CancellationToken 
cancellationToken)
+            => SendRequestResponse(command.AsBaseCommand(), cancellationToken);
 
-        public async Task<BaseCommand> Send(CommandGetLastMessageId command, 
CancellationToken cancellationToken)
-            => await SendRequestResponse(command.AsBaseCommand(), 
cancellationToken).ConfigureAwait(false);
+        public Task<BaseCommand> Send(CommandGetLastMessageId command, 
CancellationToken cancellationToken)
+            => SendRequestResponse(command.AsBaseCommand(), cancellationToken);
 
         public async Task<BaseCommand> Send(CommandCloseProducer command, 
CancellationToken cancellationToken)
         {

Reply via email to