Isolated Store wrapper

Sources/Verge/Derived/Derived.swift

@@ -19,9 +19,6 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 // THE SOFTWARE.
 
-import class Foundation.NSMapTable
-import class Foundation.NSString
-
 #if canImport(Combine)
 import Combine
 #endif
@@ -32,6 +29,20 @@ public protocol DerivedType<State>: StoreType {
   func asDerived() -> Derived<Value>
 }
 
+public protocol DerivedMaking {
+
+  associatedtype State: Equatable
+
+  // TODO: Remove
+  var state: Changes<State> { get }
+
+  func derived<Pipeline: PipelineType>(
+    _ pipeline: Pipeline,
+    queue: some TargetQueueType
+  ) -> Derived<Pipeline.Output> where Pipeline.Input == Changes<State>
+
+}
+
 /**
  A container object that provides the current value and changes from the source Store.
 
@@ -110,8 +121,8 @@ public class Derived<Value: Equatable>: Store<Value, Never>, DerivedType, @unche
         }
 
         // TODO: Take over state.modification & state.mutation
-        indirectSelf.commit("Derived") {
-          $0._transaction.isDerivedFromUpstream = true
+        indirectSelf._receive {
+          $1.isDerivedFromUpstream = true
           $0.append(traces: value.traces)
           $0.replace(with: newState)
         }
@@ -218,7 +229,7 @@ extension Derived where Value : Equatable {
     receive: @escaping (Value) -> Void
   ) -> StoreSubscription {
     sinkState(dropsFirst: dropsFirst, queue: queue) { (changes) in
-      changes.ifChanged { value in
+      changes.ifChanged().do { value in
         receive(value)
       }
     }
@@ -235,7 +246,7 @@ extension Derived where Value : Equatable {
     receive: @escaping @MainActor (Value) -> Void
   ) -> StoreSubscription {
     sinkState(dropsFirst: dropsFirst, queue: queue) { @MainActor changes in
-      changes.ifChanged { value in
+      changes.ifChanged().do { value in
         receive(value)
       }
     }

Sources/Verge/Library/InoutRef.swift

@@ -117,8 +117,6 @@ public final class InoutRef<Wrapped> {
     }
   }
 
-  public var _transaction: Transaction = .init()
-
   // MARK: - Initializers
 
   /**

Sources/Verge/Store/DispatcherType.swift

@@ -298,7 +298,7 @@ extension DispatcherType {
     )
 
     return try store.asStore()._receive(
-      mutation: { state -> Result in
+      mutation: { state, transaction -> Result in
         try state.map(keyPath: scope) { (ref: inout InoutRef<Scope>) -> Result in
           ref.append(trace: trace)
           return try mutation(&ref)
@@ -335,7 +335,7 @@ extension DispatcherType {
     mutation: (inout InoutRef<Scope>) throws -> Result
   ) rethrows -> Result where Scope == WrappedStore.State {
     return try store.asStore()._receive(
-      mutation: { ref -> Result in
+      mutation: { ref, transaction -> Result in
         ref.append(trace: trace)
         return try mutation(&ref)
       }