Method: FluQ::DSL::Feed#input

Defined in:
lib/fluq/dsl/feed.rb

#input(*type, &block) ⇒ Object

Parameters:

  • input (Array<Symbol>) —

    type path, e.g. :socket



13
14
15
16
 
# File 'lib/fluq/dsl/feed.rb', line 13

def input(*type, &block)
  klass = constantize(:input, *type)
  inputs.push [klass, FluQ::DSL::Options.new(&block).to_hash]
end