Module: Micro::Service::Pipeline

Defined in:
lib/micro/service/pipeline.rb

Defined Under Namespace

Classes: Reducer

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.[](*args) ⇒ Object 



73
74
75
 
# File 'lib/micro/service/pipeline.rb', line 73

def self.[](*args)
  Reducer.build(args)
end

.included(base) ⇒ Object 



81
82
83
84
85
86
87
88
89
90
 
# File 'lib/micro/service/pipeline.rb', line 81

def self.included(base)
  base.extend(ClassMethods)
  base.class_eval("def initialize(options)\n@options = options\npipeline = self.class.__pipeline__\nraise ArgumentError, UNDEFINED_PIPELINE unless pipeline\nend\n")
end

Instance Method Details

#call ⇒ Object 



92
93
94
 
# File 'lib/micro/service/pipeline.rb', line 92

def call
  self.class.__pipeline__.call(@options)
end