1 files changed, 6 insertions, 12 deletions
diff --git a/dsa/FireBase/ObservableExtensions.cs b/dsa/FireBase/ObservableExtensions.cs
index bc46261..69730df 100644
--- a/dsa/FireBase/ObservableExtensions.cs
+++ b/dsa/FireBase/ObservableExtensions.cs
@@ -2,34 +2,28 @@
 using System.Collections.ObjectModel;
 using Firebase.Database.Streaming;
 
-namespace Firebase.Database
-{
+namespace Firebase.Database {
     /// <summary>
     ///     Extensions for <see cref="IObservable{T}" />.
     /// </summary>
-    public static class ObservableExtensions
-    {
+    public static class ObservableExtensions {
         /// <summary>
         ///     Starts observing on given firebase observable and propagates event into an <see cref="ObservableCollection{T}" />.
         /// </summary>
         /// <param name="observable"> The observable. </param>
         /// <typeparam name="T"> Type of entity. </typeparam>
         /// <returns> The <see cref="ObservableCollection{T}" />. </returns>
-        public static ObservableCollection<T> AsObservableCollection<T>(this IObservable<FirebaseEvent<T>> observable)
-        {
+        public static ObservableCollection<T> AsObservableCollection<T>(this IObservable<FirebaseEvent<T>> observable) {
             var collection = new ObservableCollection<T>();
 
-            observable.Subscribe(f =>
-            {
-                if (f.EventType == FirebaseEventType.InsertOrUpdate)
-                {
+            observable.Subscribe(f => {
+                if (f.EventType == FirebaseEventType.InsertOrUpdate) {
                     var i = collection.IndexOf(f.Object);
                     if (i >= 0) collection.RemoveAt(i);
 
                     collection.Add(f.Object);
                 }
-                else
-                {
+                else {
                     collection.Remove(f.Object);
                 }
             });