From 761649c676b9f7a4d894a0c82d3d9c42fe1b84f8 Mon Sep 17 00:00:00 2001 From: Ivan Jiang Date: Wed, 11 Feb 2026 11:10:49 +0800 Subject: [PATCH] Remove dependency on System.Linq.Async to support .Net 10.0 --- .../AzureServiceBusConsumerClient.cs | 2 +- .../DotNetCore.CAP.AzureServiceBus.csproj | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/src/DotNetCore.CAP.AzureServiceBus/AzureServiceBusConsumerClient.cs b/src/DotNetCore.CAP.AzureServiceBus/AzureServiceBusConsumerClient.cs index 6af678e4..850825a4 100644 --- a/src/DotNetCore.CAP.AzureServiceBus/AzureServiceBusConsumerClient.cs +++ b/src/DotNetCore.CAP.AzureServiceBus/AzureServiceBusConsumerClient.cs @@ -62,7 +62,7 @@ public async Task SubscribeAsync(IEnumerable topics) topics = topics.Concat(_asbOptions!.SQLFilters?.Select(o => o.Key) ?? []); - var allRules = _administrationClient!.GetRulesAsync(_asbOptions!.TopicPath, _subscriptionName).ToEnumerable(); + var allRules = _administrationClient!.GetRulesAsync(_asbOptions!.TopicPath, _subscriptionName).ToBlockingEnumerable(); var allRuleNames = allRules.Select(o => o.Name); foreach (var newRule in topics.Except(allRuleNames)) diff --git a/src/DotNetCore.CAP.AzureServiceBus/DotNetCore.CAP.AzureServiceBus.csproj b/src/DotNetCore.CAP.AzureServiceBus/DotNetCore.CAP.AzureServiceBus.csproj index f71e80d9..b12f852b 100644 --- a/src/DotNetCore.CAP.AzureServiceBus/DotNetCore.CAP.AzureServiceBus.csproj +++ b/src/DotNetCore.CAP.AzureServiceBus/DotNetCore.CAP.AzureServiceBus.csproj @@ -18,7 +18,6 @@ -