Class: Fino::Pipeline

Inherits:

Object

• Object
• Fino::Pipeline

Extended by:

Forwardable

Defined in:

lib/fino/pipeline.rb

Instance Method Summary

• #initialize(storage, pipes = []) ⇒ Pipeline constructor

  A new instance of Pipeline.

• #use(pipe_class) ⇒ Object

Constructor Details

#initialize(storage, pipes = []) ⇒ Pipeline

Returns a new instance of Pipeline.

# File 'lib/fino/pipeline.rb', line 8

def initialize(storage, pipes = [])
  @storage = storage
  @pipes = pipes
end

Instance Method Details

#use(pipe_class) ⇒ Object

# File 'lib/fino/pipeline.rb', line 13

def use(pipe_class, ...)
  pipes << ->(pipe) { pipe_class.new(pipe, ...) }
  @pipeline = nil
end