From e6181c24124d97f2fbc932b8a68311e625463156 Mon Sep 17 00:00:00 2001
From: uzvkl <dennis.kobert@student.kit.edu>
Date: Tue, 11 Jun 2019 23:05:52 +0200
Subject: Move dsa related stuff to subfolder

---
 dsa/FireBase/ObservableExtensions.cs | 40 ++++++++++++++++++++++++++++++++++++
 1 file changed, 40 insertions(+)
 create mode 100644 dsa/FireBase/ObservableExtensions.cs

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

diff --git a/dsa/FireBase/ObservableExtensions.cs b/dsa/FireBase/ObservableExtensions.cs
new file mode 100644
index 0000000..bc46261
--- /dev/null
+++ b/dsa/FireBase/ObservableExtensions.cs
@@ -0,0 +1,40 @@
+using System;
+using System.Collections.ObjectModel;
+using Firebase.Database.Streaming;
+
+namespace Firebase.Database
+{
+    /// <summary>
+    ///     Extensions for <see cref="IObservable{T}" />.
+    /// </summary>
+    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)
+        {
+            var collection = new ObservableCollection<T>();
+
+            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
+                {
+                    collection.Remove(f.Object);
+                }
+            });
+
+            return collection;
+        }
+    }
+}
\ No newline at end of file
-- 
cgit v1.2.3-54-g00ecf