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: SeĢ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) {
