tekh/WindreamHub
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor: Methoden von 'Subscribe' auf 'Fetch' umbenannt

Browse Source
This commit is contained in:
Developer 02
2024-07-30 11:22:51 +02:00
parent 82ce7996d1
commit bcf0db1d5a
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/WindreamHub.Legacy.Client/Models/ModelExtensions.cs
View File

@@ -16,7 +16,7 @@ namespace WindreamHub.Legacy.Client.Models
return new SimplifiedResponse<TData, TError>(ok: message.IsSuccessStatusCode, status: message.StatusCode, data: data, error: err); return new SimplifiedResponse<TData, TError>(ok: message.IsSuccessStatusCode, status: message.StatusCode, data: data, error: err);
} }
public static async Task SubscribeAsync<TData, TError>(this Task<SimplifiedResponse<TData, TError>> responseAsync, Action<TData> next, Action<TError> error, CancellationToken cancellationToken = default) public static async Task FetchAsync<TData, TError>(this Task<SimplifiedResponse<TData, TError>> responseAsync, Action<TData> next, Action<TError> error, CancellationToken cancellationToken = default)
{ {
if (cancellationToken.IsCancellationRequested) if (cancellationToken.IsCancellationRequested)
return; return;
@@ -28,7 +28,7 @@ namespace WindreamHub.Legacy.Client.Models
error(res.Error); error(res.Error);
} }
public static void Subscribe<TData, TError>(this Task<SimplifiedResponse<TData, TError>> responseAsync, Action<TData> next, Action<TError> error, CancellationToken cancellationToken = default) public static void Fetch<TData, TError>(this Task<SimplifiedResponse<TData, TError>> responseAsync, Action<TData> next, Action<TError> error, CancellationToken cancellationToken = default)
{ {
Task.Run(async () => Task.Run(async () =>
{ {
@@ -43,7 +43,7 @@ namespace WindreamHub.Legacy.Client.Models
}); });
} }
public static void Subscribe<TData, TError>(this Task<SimplifiedResponse<TData, TError>> responseAsync, int millisecondsDelay, Action<TData> next, Action<TError> error = null, CancellationToken cancellationToken = default) public static void Fetch<TData, TError>(this Task<SimplifiedResponse<TData, TError>> responseAsync, int millisecondsDelay, Action<TData> next, Action<TError> error = null, CancellationToken cancellationToken = default)
{ {
Task.Run(async () => Task.Run(async () =>
{ {
@@ -60,7 +60,7 @@ namespace WindreamHub.Legacy.Client.Models
}); });
} }
public static Func<Task> CreateSubscribeAsyncAction<TData, TError>(this Task<SimplifiedResponse<TData, TError>> responseAsync, Action<TData> next, Action<TError> error = null, CancellationToken cancellationToken = default) public static Func<Task> CreateFetchAsyncAction<TData, TError>(this Task<SimplifiedResponse<TData, TError>> responseAsync, Action<TData> next, Action<TError> error = null, CancellationToken cancellationToken = default)
{ {
return async () => return async () =>
{ {
@@ -75,7 +75,7 @@ namespace WindreamHub.Legacy.Client.Models
}; };
} }
public static Action CreateSubscribeAction<TData, TError>(this Task<SimplifiedResponse<TData, TError>> responseAsync, Action<TData> next, Action<TError> error = null, CancellationToken cancellationToken = default) public static Action CreateFetchAction<TData, TError>(this Task<SimplifiedResponse<TData, TError>> responseAsync, Action<TData> next, Action<TError> error = null, CancellationToken cancellationToken = default)
{ {
return () => Task.Run(async () => return () => Task.Run(async () =>
{ {