pipe.rb in rom-repository-1.0.0

- old
+ new

@@ -1,30 +1,39 @@
 require 'transproc/registry'
 require 'transproc/transformer'
 
 module ROM
   class Changeset
-    # Composable data transformation pipe used by default in changesets
+    # Transproc Registry useful for pipe
     #
     # @api private
-    class Pipe < Transproc::Transformer
+    module PipeRegistry
       extend Transproc::Registry
 
       import Transproc::HashTransformations
 
-      attr_reader :processor
-
       def self.add_timestamps(data)
         now = Time.now
         data.merge(created_at: now, updated_at: now)
       end
 
       def self.touch(data)
         data.merge(updated_at: Time.now)
       end
+    end
 
+    # Composable data transformation pipe used by default in changesets
+    #
+    # @api private
+    class Pipe < Transproc::Transformer[PipeRegistry]
+      attr_reader :processor
+
       def initialize(processor = self.class.transproc)
         @processor = processor
+      end
+
+      def self.[](name)
+        container[name]
       end
 
       def [](name)
         self.class[name]
       end