just/Just.Railway
1
0
Fork 0
Code Issues Pull Requests Actions Packages Releases 11 Activity

added Tap extensions generator
All checks were successful
.NET Test / test (push) Successful in 3m17s
Details
.NET Publish / publish (push) Successful in 3m8s
Details

Browse Source
This commit is contained in:
JustFixMe
2023-11-28 22:10:28 +04:00
parent 6726ba07b3
commit 0452b4f867
3 changed files with 114 additions and 284 deletions
Download Patch File Download Diff File Expand all files Collapse all files

285
Railway/ResultExtensions.cs
View File

@@ -686,7 +686,7 @@ public static partial class ResultExtensions
#endregion
#region Tap
#region Tap<>
[Pure]
public static ref readonly Result Tap(this in Result result, Action? onSuccess = null, Action<Error>? onFailure = null)
{
@@ -762,289 +762,6 @@ public static partial class ResultExtensions
return result;
}
[Pure]
public static ref readonly Result<T> Tap<T>(this in Result<T> result, Action<T>? onSuccess = null, Action<Error>? onFailure = null)
{
switch (result.State)
{
case ResultState.Success:
onSuccess?.Invoke(result.Value!);
break;
case ResultState.Error:
onFailure?.Invoke(result.Error!);
break;
default: throw new ResultNotInitializedException(nameof(result));
}
return ref result;
}
[Pure]
public static async Task<Result<T>> Tap<T>(this Task<Result<T>> resultTask, Action<T>? onSuccess = null, Action<Error>? onFailure = null)
{
var result = await resultTask.ConfigureAwait(false);
switch (result.State)
{
case ResultState.Success:
onSuccess?.Invoke(result.Value!);
break;
case ResultState.Error:
onFailure?.Invoke(result.Error!);
break;
default: throw new ResultNotInitializedException(nameof(resultTask));
}
return result;
}
[Pure]
public static async Task<Result<T>> Tap<T>(this Result<T> result, Func<T, Task>? onSuccess = null, Func<Error, Task>? onFailure = null)
{
switch (result.State)
{
case ResultState.Success:
if (onSuccess is not null)
await onSuccess.Invoke(result.Value!).ConfigureAwait(false);
break;
case ResultState.Error:
if (onFailure is not null)
await onFailure.Invoke(result.Error!).ConfigureAwait(false);
break;
default: throw new ResultNotInitializedException(nameof(result));
}
return result;
}
[Pure]
public static async Task<Result<T>> Tap<T>(this Task<Result<T>> resultTask, Func<T, Task>? onSuccess = null, Func<Error, Task>? onFailure = null)
{
var result = await resultTask.ConfigureAwait(false);
switch (result.State)
{
case ResultState.Success:
if (onSuccess is not null)
await onSuccess.Invoke(result.Value!).ConfigureAwait(false);
break;
case ResultState.Error:
if (onFailure is not null)
await onFailure.Invoke(result.Error!).ConfigureAwait(false);
break;
default: throw new ResultNotInitializedException(nameof(resultTask));
}
return result;
}
[Pure]
public static ref readonly Result<(T1, T2)> Tap<T1, T2>(this in Result<(T1, T2)> result, Action<T1, T2>? onSuccess = null, Action<Error>? onFailure = null)
{
switch (result.State)
{
case ResultState.Success:
onSuccess?.Invoke(result.Value.Item1, result.Value.Item2);
break;
case ResultState.Error:
onFailure?.Invoke(result.Error!);
break;
default: throw new ResultNotInitializedException(nameof(result));
}
return ref result;
}
[Pure]
public static async Task<Result<(T1, T2)>> Tap<T1, T2>(this Task<Result<(T1, T2)>> resultTask, Action<T1, T2>? onSuccess = null, Action<Error>? onFailure = null)
{
var result = await resultTask.ConfigureAwait(false);
switch (result.State)
{
case ResultState.Success:
onSuccess?.Invoke(result.Value.Item1, result.Value.Item2);
break;
case ResultState.Error:
onFailure?.Invoke(result.Error!);
break;
default: throw new ResultNotInitializedException(nameof(resultTask));
}
return result;
}
[Pure]
public static async Task<Result<(T1, T2)>> Tap<T1, T2>(this Result<(T1, T2)> result, Func<T1, T2, Task>? onSuccess = null, Func<Error, Task>? onFailure = null)
{
switch (result.State)
{
case ResultState.Success:
if (onSuccess is not null)
await onSuccess.Invoke(result.Value.Item1, result.Value.Item2).ConfigureAwait(false);
break;
case ResultState.Error:
if (onFailure is not null)
await onFailure.Invoke(result.Error!).ConfigureAwait(false);
break;
default: throw new ResultNotInitializedException(nameof(result));
}
return result;
}
[Pure]
public static async Task<Result<(T1, T2)>> Tap<T1, T2>(this Task<Result<(T1, T2)>> resultTask, Func<T1, T2, Task>? onSuccess = null, Func<Error, Task>? onFailure = null)
{
var result = await resultTask.ConfigureAwait(false);
switch (result.State)
{
case ResultState.Success:
if (onSuccess is not null)
await onSuccess.Invoke(result.Value.Item1, result.Value.Item2).ConfigureAwait(false);
break;
case ResultState.Error:
if (onFailure is not null)
await onFailure.Invoke(result.Error!).ConfigureAwait(false);
break;
default: throw new ResultNotInitializedException(nameof(resultTask));
}
return result;
}
[Pure]
public static ref readonly Result<(T1, T2, T3)> Tap<T1, T2, T3>(this in Result<(T1, T2, T3)> result, Action<T1, T2, T3>? onSuccess = null, Action<Error>? onFailure = null)
{
switch (result.State)
{
case ResultState.Success:
onSuccess?.Invoke(result.Value.Item1, result.Value.Item2, result.Value.Item3);
break;
case ResultState.Error:
onFailure?.Invoke(result.Error!);
break;
default: throw new ResultNotInitializedException(nameof(result));
}
return ref result;
}
[Pure]
public static async Task<Result<(T1, T2, T3)>> Tap<T1, T2, T3>(this Task<Result<(T1, T2, T3)>> resultTask, Action<T1, T2, T3>? onSuccess = null, Action<Error>? onFailure = null)
{
var result = await resultTask.ConfigureAwait(false);
switch (result.State)
{
case ResultState.Success:
onSuccess?.Invoke(result.Value.Item1, result.Value.Item2, result.Value.Item3);
break;
case ResultState.Error:
onFailure?.Invoke(result.Error!);
break;
default: throw new ResultNotInitializedException(nameof(resultTask));
}
return result;
}
[Pure]
public static async Task<Result<(T1, T2, T3)>> Tap<T1, T2, T3>(this Result<(T1, T2, T3)> result, Func<T1, T2, T3, Task>? onSuccess = null, Func<Error, Task>? onFailure = null)
{
switch (result.State)
{
case ResultState.Success:
if (onSuccess is not null)
await onSuccess.Invoke(result.Value.Item1, result.Value.Item2, result.Value.Item3).ConfigureAwait(false);
break;
case ResultState.Error:
if (onFailure is not null)
await onFailure.Invoke(result.Error!).ConfigureAwait(false);
break;
default: throw new ResultNotInitializedException(nameof(result));
}
return result;
}
[Pure]
public static async Task<Result<(T1, T2, T3)>> Tap<T1, T2, T3>(this Task<Result<(T1, T2, T3)>> resultTask, Func<T1, T2, T3, Task>? onSuccess = null, Func<Error, Task>? onFailure = null)
{
var result = await resultTask.ConfigureAwait(false);
switch (result.State)
{
case ResultState.Success:
if (onSuccess is not null)
await onSuccess.Invoke(result.Value.Item1, result.Value.Item2, result.Value.Item3).ConfigureAwait(false);
break;
case ResultState.Error:
if (onFailure is not null)
await onFailure.Invoke(result.Error!).ConfigureAwait(false);
break;
default: throw new ResultNotInitializedException(nameof(resultTask));
}
return result;
}
[Pure]
public static ref readonly Result<(T1, T2, T3, T4)> Tap<T1, T2, T3, T4>(this in Result<(T1, T2, T3, T4)> result, Action<T1, T2, T3, T4>? onSuccess = null, Action<Error>? onFailure = null)
{
switch (result.State)
{
case ResultState.Success:
onSuccess?.Invoke(result.Value.Item1, result.Value.Item2, result.Value.Item3, result.Value.Item4);
break;
case ResultState.Error:
onFailure?.Invoke(result.Error!);
break;
default: throw new ResultNotInitializedException(nameof(result));
}
return ref result;
}
[Pure]
public static async Task<Result<(T1, T2, T3, T4)>> Tap<T1, T2, T3, T4>(this Task<Result<(T1, T2, T3, T4)>> resultTask, Action<T1, T2, T3, T4>? onSuccess = null, Action<Error>? onFailure = null)
{
var result = await resultTask.ConfigureAwait(false);
switch (result.State)
{
case ResultState.Success:
onSuccess?.Invoke(result.Value.Item1, result.Value.Item2, result.Value.Item3, result.Value.Item4);
break;
case ResultState.Error:
onFailure?.Invoke(result.Error!);
break;
default: throw new ResultNotInitializedException(nameof(resultTask));
}
return result;
}
[Pure]
public static async Task<Result<(T1, T2, T3, T4)>> Tap<T1, T2, T3, T4>(this Result<(T1, T2, T3, T4)> result, Func<T1, T2, T3, T4, Task>? onSuccess = null, Func<Error, Task>? onFailure = null)
{
switch (result.State)
{
case ResultState.Success:
if (onSuccess is not null)
await onSuccess.Invoke(result.Value.Item1, result.Value.Item2, result.Value.Item3, result.Value.Item4).ConfigureAwait(false);
break;
case ResultState.Error:
if (onFailure is not null)
await onFailure.Invoke(result.Error!).ConfigureAwait(false);
break;
default: throw new ResultNotInitializedException(nameof(result));
}
return result;
}
[Pure]
public static async Task<Result<(T1, T2, T3, T4)>> Tap<T1, T2, T3, T4>(this Task<Result<(T1, T2, T3, T4)>> resultTask, Func<T1, T2, T3, T4, Task>? onSuccess = null, Func<Error, Task>? onFailure = null)
{
var result = await resultTask.ConfigureAwait(false);
switch (result.State)
{
case ResultState.Success:
if (onSuccess is not null)
await onSuccess.Invoke(result.Value.Item1, result.Value.Item2, result.Value.Item3, result.Value.Item4).ConfigureAwait(false);
break;
case ResultState.Error:
if (onFailure is not null)
await onFailure.Invoke(result.Error!).ConfigureAwait(false);
break;
default: throw new ResultNotInitializedException(nameof(resultTask));
}
return result;
}
#endregion
#region Merge