Ensure all state recovery changes are serialized

SainsburyWellcomeCentre · May 15, 2024 · 818239a · 818239a
1 parent bb17c51
commit 818239a
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/Aeon.Acquisition/StateRecoverySubject.cs b/src/Aeon.Acquisition/StateRecoverySubject.cs
@@ -2,6 +2,7 @@
 using System;
 using System.ComponentModel;
 using System.Linq.Expressions;
+using System.Reactive.Linq;
 using System.Reactive.Subjects;
 
 namespace Aeon.Acquisition
@@ -39,11 +40,9 @@ public RecoverySubject(string name)
             {
                 var state = StateRecovery<T>.Deserialize(name);
                 subject = new BehaviorSubject<T>(state);
-                Name = name;
+                subject.Skip(1).Subscribe(value => StateRecovery<T>.Serialize(name, value));
             }
 
-            string Name { get; }
-
             public void OnCompleted()
             {
             }
@@ -64,7 +63,6 @@ public IDisposable Subscribe(IObserver<T> observer)
 
             public void Dispose()
             {
-                StateRecovery<T>.Serialize(Name, subject.Value);
                 subject.Dispose();
             }
         }