summaryrefslogtreecommitdiff
path: root/dsa/FireBase/Extensions
diff options
context:
space:
mode:
authorDennis Kobert <d-kobert@web.de>2019-06-12 21:47:51 +0200
committerDennis Kobert <d-kobert@web.de>2019-06-12 21:47:51 +0200
commit304437b834e8c87687f68333ae67a13ee1377a73 (patch)
tree51dd246568e8a159627d9cb92e99890adb5cbef8 /dsa/FireBase/Extensions
parent2fa4a0e50ebfc97059c8b84dbd17e79f9afc8a8d (diff)
Adjust Codestyle
Diffstat (limited to 'dsa/FireBase/Extensions')
-rw-r--r--dsa/FireBase/Extensions/ObservableExtensions.cs12
-rw-r--r--dsa/FireBase/Extensions/TaskExtensions.cs15
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;
}
}