diff options
Diffstat (limited to 'dsa/FireBase/Extensions')
-rw-r--r-- | dsa/FireBase/Extensions/ObservableExtensions.cs | 12 | ||||
-rw-r--r-- | dsa/FireBase/Extensions/TaskExtensions.cs | 15 |
2 files changed, 9 insertions, 18 deletions
diff --git a/dsa/FireBase/Extensions/ObservableExtensions.cs b/dsa/FireBase/Extensions/ObservableExtensions.cs index 0a672d7..1dae7e9 100644 --- a/dsa/FireBase/Extensions/ObservableExtensions.cs +++ b/dsa/FireBase/Extensions/ObservableExtensions.cs @@ -1,10 +1,8 @@ using System; using System.Reactive.Linq; -namespace Firebase.Database.Extensions -{ - public static class ObservableExtensions - { +namespace Firebase.Database.Extensions { + public static class ObservableExtensions { /// <summary> /// Returns a cold observable which retries (re-subscribes to) the source observable on error until it successfully /// terminates. @@ -20,12 +18,10 @@ namespace Firebase.Database.Extensions this IObservable<T> source, TimeSpan dueTime, Func<TException, bool> retryOnError) - where TException : Exception - { + where TException : Exception { var attempt = 0; - return Observable.Defer(() => - { + return Observable.Defer(() => { return (++attempt == 1 ? source : source.DelaySubscription(dueTime)) .Select(item => new Tuple<bool, T, Exception>(true, item, null)) .Catch<Tuple<bool, T, Exception>, TException>(e => retryOnError(e) diff --git a/dsa/FireBase/Extensions/TaskExtensions.cs b/dsa/FireBase/Extensions/TaskExtensions.cs index c955b3a..68d4538 100644 --- a/dsa/FireBase/Extensions/TaskExtensions.cs +++ b/dsa/FireBase/Extensions/TaskExtensions.cs @@ -1,21 +1,16 @@ using System; using System.Threading.Tasks; -namespace Firebase.Database.Extensions -{ - public static class TaskExtensions - { +namespace Firebase.Database.Extensions { + public static class TaskExtensions { /// <summary> /// Instead of unwrapping <see cref="AggregateException" /> it throws it as it is. /// </summary> - public static async Task WithAggregateException(this Task source) - { - try - { + public static async Task WithAggregateException(this Task source) { + try { await source.ConfigureAwait(false); } - catch (Exception ex) - { + catch (Exception ex) { throw source.Exception ?? ex; } } |