AppStd/Leanetec.EConnect
8
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(EConnectClient): add json serilization options to EConnectClient

Browse Source
This commit is contained in:
tekh 2025-08-15 14:10:19 +02:00
parent 6836b422a4
commit 3082c0b77c
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Leanetec.EConnect.Infrastructure/EConnectClient.cs
View File

@ -34,12 +34,12 @@ public class EConnectClient<TError> : IEConnectClient<TError> where TError : cl
if (res.IsSuccessStatusCode) if (res.IsSuccessStatusCode)
{ {
var data = await res.Content.ReadFromJsonAsync<TData>(cancel); var data = await res.Content.ReadFromJsonAsync<TData>(_options.JsonSerializerOptions, cancel);
return new Response<TData, TError>(true, Data: data); return new Response<TData, TError>(true, Data: data);
} }
else else
{ {
var error = await res.Content.ReadFromJsonAsync<TError>(cancel); var error = await res.Content.ReadFromJsonAsync<TError>(_options.JsonSerializerOptions, cancel);
return new Response<TData, TError>(false, Error: error); return new Response<TData, TError>(false, Error: error);
} }
} }
@ -59,13 +59,13 @@ public class EConnectClient<TError> : IEConnectClient<TError> where TError : cl
if (res.IsSuccessStatusCode) if (res.IsSuccessStatusCode)
{ {
var data = res.Content.ReadFromJsonAsAsyncEnumerable<TData>(cancel); var data = res.Content.ReadFromJsonAsAsyncEnumerable<TData>(_options.JsonSerializerOptions, cancel);
return new Response<IAsyncEnumerable<TData?>, TError>(true, Data: data); return new Response<IAsyncEnumerable<TData?>, TError>(true, Data: data);
} }
else else
{ {
var error = await res.Content.ReadFromJsonAsync<TError>(cancellationToken: cancel); var error = await res.Content.ReadFromJsonAsync<TError>(_options.JsonSerializerOptions, cancel);
return new Response<IAsyncEnumerable<TData?>, TError>(false, Error: error); return new Response<IAsyncEnumerable<TData?>, TError>(false, Error: error);
} }
} }
} }