lib/rom/repository/changeset/pipe.rb in rom-repository-1.0.0.beta2 vs lib/rom/repository/changeset/pipe.rb in rom-repository-1.0.0.beta3

@@ -25,9 +25,17 @@
 
       def [](name)
         self.class[name]
       end
 
+      def bind(context)
+        if processor.is_a?(Proc)
+          self.class.new(Pipe[-> *args { context.instance_exec(*args, &processor) }])
+        else
+          self
+        end
+      end
+
       def >>(other)
         if processor
           Pipe.new(processor >> other)
         else
           Pipe.new(other)