Fixed init of continuation

YohDeadfall · Dec 25, 2023 · 3d65770 · 3d65770
1 parent b83581a
commit 3d65770
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/Kinetic/Linq/ObservableView.SelectAsync.cs b/src/Kinetic/Linq/ObservableView.SelectAsync.cs
@@ -329,4 +329,4 @@ public void Create<TContinuation>(in TContinuation continuation, ObserverStateMa
             where TContinuation : struct, IObserverStateMachine<ObservableViewItem<T>> =>
             source.ContinueWith(new SelectorStateMachine<T, TContinuation>(continuation, _item));
     }
-}
+}
diff --git a/src/Kinetic/Linq/ObservableView.Where.cs b/src/Kinetic/Linq/ObservableView.Where.cs
@@ -265,7 +265,8 @@ public WherePredicateStateMachine(in TContinuation continuation, WhereStateMachi
         public void Dispose() =>
             _continuation.Dispose();
 
-        public void Initialize(ObserverStateMachineBox box) { }
+        public void Initialize(ObserverStateMachineBox box) =>
+            _continuation.Initialize(box);
 
         public void OnCompleted() =>
             _continuation.OnCompleted();
-Original file line number
+Diff line change
@@ Expand Up @@
                 where TContinuation : struct, IObserverStateMachine<ObservableViewItem<T>> =>
                 source.ContinueWith(new SelectorStateMachine<T, TContinuation>(continuation, _item));
         }
-    }
+    }