feat: allow logging state changes

dominiksta · Jun 25, 2024 · 13c9395 · 13c9395
1 parent 16483b2
commit 13c9395
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/packages/core/src/rx/state.ts b/packages/core/src/rx/state.ts
@@ -26,7 +26,14 @@ export default class State<T> extends MulticastStream<T> {
   /** The current value/state */
   get value() { return this._value }
 
-  constructor(private initialValue: T) {
+  public static loggingCallback?:
+    (name: string | undefined, previous: any, next: any) => void = undefined;
+
+  constructor(
+    private initialValue: T,
+    private loggingName?: string,
+    private loggingCallback = State.loggingCallback,
+  ) {
     super();
     this._value = initialValue;
   }
@@ -50,6 +57,8 @@ export default class State<T> extends MulticastStream<T> {
     if (this.completed) return;
     const newValue = valueOrSetter instanceof Function ?
       valueOrSetter(this._value) : valueOrSetter;
+    if (this.loggingCallback !== undefined && this.loggingName !== undefined)
+      this.loggingCallback(this.loggingName, this._value, newValue);
     this._value = newValue;
     super.next(newValue);
   }