async await

phongnguyend · Dec 5, 2024 · b0c4e28 · b0c4e28
1 parent a7ec744
commit b0c4e28
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 9 deletions.
diff --git a/...Common/ClassifiedAds.Infrastructure/HostedServices/MessageBusConsumerBackgroundService.cs b/...Common/ClassifiedAds.Infrastructure/HostedServices/MessageBusConsumerBackgroundService.cs
@@ -19,9 +19,8 @@ public MessageBusConsumerBackgroundService(ILogger<MessageBusConsumerBackgroundS
         _messageBus = messageBus;
     }
 
-    protected override Task ExecuteAsync(CancellationToken stoppingToken)
+    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
     {
-        _messageBus.ReceiveAsync<TConsumer, T>(stoppingToken);
-        return Task.CompletedTask;
+        await _messageBus.ReceiveAsync<TConsumer, T>(stoppingToken);
     }
 }
diff --git a/...nolith/ClassifiedAds.Infrastructure/HostedServices/MessageBusConsumerBackgroundService.cs b/...nolith/ClassifiedAds.Infrastructure/HostedServices/MessageBusConsumerBackgroundService.cs
@@ -19,9 +19,8 @@ public MessageBusConsumerBackgroundService(ILogger<MessageBusConsumerBackgroundS
         _messageBus = messageBus;
     }
 
-    protected override Task ExecuteAsync(CancellationToken cancellationToken)
+    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
     {
-        _messageBus.ReceiveAsync<TConsumer, T>(cancellationToken);
-        return Task.CompletedTask;
+        await _messageBus.ReceiveAsync<TConsumer, T>(stoppingToken);
     }
 }
diff --git a/...nolith/ClassifiedAds.Infrastructure/HostedServices/MessageBusConsumerBackgroundService.cs b/...nolith/ClassifiedAds.Infrastructure/HostedServices/MessageBusConsumerBackgroundService.cs
@@ -19,9 +19,8 @@ public MessageBusConsumerBackgroundService(ILogger<MessageBusConsumerBackgroundS
         _messageBus = messageBus;
     }
 
-    protected override Task ExecuteAsync(CancellationToken stoppingToken)
+    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
     {
-        _messageBus.ReceiveAsync<TConsumer, T>(stoppingToken);
-        return Task.CompletedTask;
+        await _messageBus.ReceiveAsync<TConsumer, T>(stoppingToken);
     }
 }