Ruby-Pipeline example

require 'pipeline'$stdout.sync = truepipeline \  lambda {|q|    # Generate numbers 1..100 slowly.    1.upto(100) do |i|      q << i      sleep 0.1    end  },  lambda {|q|    # Pop two numbers, push their product.    q.shift(2) do |i,j|      q << i*j    end  },  lambda {|q|    # Print incoming numbers.    q.shift do |i|      print i, ' '    end    puts  }