summaryrefslogtreecommitdiff
path: root/dsa/FireBase/ObservableExtensions.cs
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/ObservableExtensions.cs
parent2fa4a0e50ebfc97059c8b84dbd17e79f9afc8a8d (diff)
Adjust Codestyle
Diffstat (limited to 'dsa/FireBase/ObservableExtensions.cs')
-rw-r--r--dsa/FireBase/ObservableExtensions.cs18
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);
}
});