Cleanup DiscoBot Project

1 files changed, 14 insertions, 14 deletions

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