Skip to content

Commit 006a145

Browse files
MayueCifzhenlei520Mayue
authored
Refactor/elasticsearch (#394)
* feat: AutoComplete SupportUpdate * refactor: Elasticsearch SupportUpdate * feat(Es): autoComplete Support alwaysGetNewestElasticClient * test: Modify unit tests * test: Modify unit tests * feat: Add Elasticsearch Client * feat(Caller): Caller supports synchronous calling asynchronous * test: Adjust unit test coverage * feat:remove stack sdk async Co-authored-by: zhenlei520 <wangzhenlei520@gmail.com> Co-authored-by: Mayue <mayue@lonsid.cn>
1 parent 717d764 commit 006a145

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

src/Contrib/Configuration/ConfigurationApi/Masa.Contrib.Configuration.ConfigurationApi.Dcc/ConfigurationApiClient.cs

+1-1
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ private async Task<dynamic> GetDynamicInternalAsync(string key, Action<string, d
118118
var raw = await GetRawByKeyAsync(k, value =>
119119
{
120120
valueChanged?.Invoke(k, value, _dynamicJsonSerializerOptions);
121-
});
121+
}).ConfigureAwait(false);
122122
return JsonSerializer.Deserialize<ExpandoObject>(raw.Raw, _dynamicJsonSerializerOptions) ?? throw new ArgumentException(key);
123123
})).Value.ConfigureAwait(false);
124124

src/Contrib/StackSdks/Masa.Contrib.StackSdks.Mc/ServiceCollectionExtensions.cs

+3-3
Original file line numberDiff line numberDiff line change
@@ -20,15 +20,15 @@ public static IServiceCollection AddMcClient(this IServiceCollection services, s
2020
});
2121
}
2222

23-
public static IServiceCollection AddMcClient(this IServiceCollection services, Func<Task<string>> mcServiceBaseAddressFunc)
23+
public static IServiceCollection AddMcClient(this IServiceCollection services, Func<string> mcServiceBaseAddressFunc)
2424
{
2525
MasaArgumentException.ThrowIfNull(mcServiceBaseAddressFunc);
2626

2727
return services.AddMcClient(callerOptions =>
2828
{
29-
callerOptions.UseHttpClient(DEFAULT_CLIENT_NAME, async builder =>
29+
callerOptions.UseHttpClient(DEFAULT_CLIENT_NAME, builder =>
3030
{
31-
builder.BaseAddress = await mcServiceBaseAddressFunc.Invoke();
31+
builder.BaseAddress = mcServiceBaseAddressFunc.Invoke();
3232
}, true).AddHttpMessageHandler<HttpClientAuthorizationDelegatingHandler>();
3333
callerOptions.DisableAutoRegistration = true;
3434
});

src/Contrib/StackSdks/Masa.Contrib.StackSdks.Pm/ServiceCollectionExtensions.cs

+3-3
Original file line numberDiff line numberDiff line change
@@ -20,15 +20,15 @@ public static IServiceCollection AddPmClient(this IServiceCollection services, s
2020
});
2121
}
2222

23-
public static IServiceCollection AddPmClient(this IServiceCollection services, Func<Task<string>> pmServiceBaseAddressFunc)
23+
public static IServiceCollection AddPmClient(this IServiceCollection services, Func<string> pmServiceBaseAddressFunc)
2424
{
2525
MasaArgumentException.ThrowIfNull(pmServiceBaseAddressFunc);
2626

2727
return services.AddPmClient(callerOptions =>
2828
{
29-
callerOptions.UseHttpClient(DEFAULT_CLIENT_NAME, async builder =>
29+
callerOptions.UseHttpClient(DEFAULT_CLIENT_NAME, builder =>
3030
{
31-
builder.BaseAddress = await pmServiceBaseAddressFunc.Invoke();
31+
builder.BaseAddress = pmServiceBaseAddressFunc.Invoke();
3232
}, true);
3333
callerOptions.DisableAutoRegistration = true;
3434
});

0 commit comments

Comments
 (0)