From e25de16f65646af2a18479c5d645d0a74cf615b3 Mon Sep 17 00:00:00 2001
From: ig <ig ig@devnullmail.com>
Date: Tue, 21 Mar 2023 11:40:23 +0100
Subject: [PATCH] Run CleanUp on TaskPool

---
 csharp/App/Backend/Database/Db.cs | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/csharp/App/Backend/Database/Db.cs b/csharp/App/Backend/Database/Db.cs
index 80cd15454..ebdab555c 100644
--- a/csharp/App/Backend/Database/Db.cs
+++ b/csharp/App/Backend/Database/Db.cs
@@ -1,3 +1,4 @@
+using System.Reactive.Concurrency;
 using System.Reactive.Linq;
 using InnovEnergy.App.Backend.DataTypes;
 using InnovEnergy.App.Backend.DataTypes.Methods;
@@ -15,10 +16,10 @@ public static partial class Db
 
     private static SQLiteConnection Connection { get; } = new SQLiteConnection(DbPath);
 
-    public static TableQuery<Session>           Sessions          => Connection.Table<Session>();
-    public static TableQuery<Folder>            Folders           => Connection.Table<Folder>();
-    public static TableQuery<Installation>      Installations     => Connection.Table<Installation>();
-    public static TableQuery<User>              Users             => Connection.Table<User>();
+    public static TableQuery<Session>            Sessions           => Connection.Table<Session>();
+    public static TableQuery<Folder>             Folders            => Connection.Table<Folder>();
+    public static TableQuery<Installation>       Installations      => Connection.Table<Installation>();
+    public static TableQuery<User>               Users              => Connection.Table<User>();
     public static TableQuery<FolderAccess>       FolderAccess       => Connection.Table<FolderAccess>();
     public static TableQuery<InstallationAccess> InstallationAccess => Connection.Table<InstallationAccess>();
 
@@ -38,9 +39,10 @@ public static partial class Db
         });
 
         Observable.Interval(TimeSpan.FromDays(0.5))
-                  .StartWith(0) // Do it right away (on startup)
+                  .StartWith(0)         // Do it right away (on startup)      
+                  .ObserveOn(TaskPoolScheduler.Default)
                   .SelectMany(Cleanup)
-                  .Subscribe();         // and then daily
+                  .Subscribe();
     }