sujoyg / pipelines Goto Github PK

~/gems/ruby-1.9.3-p194/gems/tubes-0.1.17/lib/tubes.rb:79:in `initialize': wrong number of arguments(2 for 0) (ArgumentError)
    from /Users/topprospect/.rvm/gems/ruby-1.9.3-p194/gems/tubes-0.1.17/lib/tubes.rb:79:in `new'
    from /Users/topprospect/.rvm/gems/ruby-1.9.3-p194/gems/tubes-0.1.17/lib/tubes.rb:79:in `invoke'

class LettersTask # oops, forgot < Tube
  def run
    ('A'..'J').map do |char|
      char
    end
  end
end

class Tasks < Tube
  def run
    parallel do
      invoke LettersTask
      invoke LettersTask
    end    
  end
end


if __FILE__ == $0
  tube = Tasks.new
  tube.run
end

class Tasks < Tube
  def run
    parallel do
      invoke NumbersTask
      invoke LettersTask
    end
    output
  end
end

    tube = Tasks.new
    tube.run
    results = tube.output
    do_something_with(results)

    results = Tasks.new.run
    do_something_with(results)

```However, run always returns nil.

 [ {:number => 1}, {:number =>2} ]

[ {'number' => 1}, {'number' =>2} ]