From f89f308c525e9deebc6d2cf6416e27dfe1a299dc Mon Sep 17 00:00:00 2001
From: Dennis Kobert <d-kobert@web.de>
Date: Sun, 19 May 2019 16:03:38 +0200
Subject: Cleanup DiscoBot Project

---
 FireBase/Extensions/ObservableExtensions.cs | 28 ++++++++++++++--------------
 1 file changed, 14 insertions(+), 14 deletions(-)

(limited to 'FireBase/Extensions/ObservableExtensions.cs')

diff --git a/FireBase/Extensions/ObservableExtensions.cs b/FireBase/Extensions/ObservableExtensions.cs
index 12cd5f3..cb41bcc 100644
--- a/FireBase/Extensions/ObservableExtensions.cs
+++ b/FireBase/Extensions/ObservableExtensions.cs
@@ -19,22 +19,22 @@
             this IObservable<T> source,
             TimeSpan dueTime,
             Func<TException, bool> retryOnError)
-            where TException: Exception
+            where TException : Exception
         {
-            int attempt = 0;
+            var attempt = 0;
 
             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)
-                        ? Observable.Throw<Tuple<bool, T, Exception>>(e)
-                        : Observable.Return(new Tuple<bool, T, Exception>(false, default(T), e)));
-            })
-            .Retry()
-            .SelectMany(t => t.Item1
-                ? Observable.Return(t.Item2)
-                : Observable.Throw<T>(t.Item3));
+                {
+                    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)
+                            ? Observable.Throw<Tuple<bool, T, Exception>>(e)
+                            : Observable.Return(new Tuple<bool, T, Exception>(false, default(T), e)));
+                })
+                .Retry()
+                .SelectMany(t => t.Item1
+                    ? Observable.Return(t.Item2)
+                    : Observable.Throw<T>(t.Item3));
         }
     }
-}
+}
\ No newline at end of file
-- 
cgit v1.2.3-54-g00ecf