Module: ROM::Pipeline Private

Includes:
Operator
Included in:
Commands::Graph, Relation, Relation::Curried, Relation::Graph
Defined in:
lib/rom/pipeline.rb

Overview

This module is part of a private API. You should avoid using this module if possible, as it may be removed or be changed in the future.

Data pipeline common interface

Defined Under Namespace

Modules: Operator, Proxy Classes: Composite

Instance Method Summary collapse

Methods included from Operator

#>>

Instance Method Details

#map_with(*names) ⇒ Relation::Composite

Send data through specified mappers

Returns:



41
42
43
44
 
# File 'lib/rom/pipeline.rb', line 41

def map_with(*names)
  [self, *names.map { |name| mappers[name] }]
    .reduce { |a, e| composite_class.new(a, e) }
end