Not logging restore sources

packages/event-reduce/src/logging.ts

@@ -1,5 +1,6 @@
 import { sendEvent } from "./devtools";
 import { IObservable, Observable } from "./observable";
+import { RestoreSubject } from "./reduction";
 
 let loggingEnabled = false;
 
@@ -89,14 +90,16 @@ export interface ISourceInfo {
 
 export function sourceTree(sources: readonly IObservable<any>[]): ISourceInfo[] {
     if (process.env.NODE_ENV !== 'production')
-        return sources.map(s => {
-            let source = new WeakRef(s);
-            return {
-                name: s.displayName,
-                sources: (s as Observable<any>).sourceInfo,
-                get observable() { return source.deref() ?? "No longer in memory"; }
-            }
-        });
+        return sources
+            .filter(s => !(s instanceof RestoreSubject)) // Since every reduction has a restore source, this is just noise
+            .map(s => {
+                let source = new WeakRef(s);
+                return {
+                    name: s.displayName,
+                    sources: (s as Observable<any>).sourceInfo,
+                    get observable() { return source.deref() ?? "No longer in memory"; }
+                }
+            });
     else
         return [];
 }

packages/event-reduce/src/reduction.ts

@@ -29,7 +29,7 @@ export interface IBoundReduction<T, TEvents> extends IReduction<T> {
 
 export class Reduction<T> extends ObservableValue<T> implements IReduction<T> {
     private _sources = new Map<IObservable<any>, Unsubscribe>();
-    private _restore = new Subject<State<T>>(() => `${this.displayName}.restored`);
+    private _restore = new RestoreSubject<State<T>>(() => `${this.displayName}.restored`);
 
     constructor(getDisplayName: () => string, initial: T) {
         super(getDisplayName, initial);
@@ -103,6 +103,8 @@ class BoundReduction<TValue, TEvents> extends Reduction<TValue> implements IBoun
     }
 }
 
+export class RestoreSubject<T> extends Subject<T> { }
+
 export class CircularSubscriptionError extends Error {
     constructor(
         public reduction: IReduction<unknown>,