Contents

require 'spec_helper'
# require 'wukong'
# require 'wukong/local_runner'

# describe Wukong::LocalRunner, :examples_spec => true, :helpers => true do

#   context 'examples' do

#     subject{
#       test_sink = test_sink()
#       Wukong.dataflow(:integers) do
#         input   :default, Wukong::Source::Integers.new(:size => 100)
#         output  :default, test_sink

#         input(:default)  >
#           map(&:to_s)    >
#           re(/..+/)      >
#           map(&:reverse) >
#           limit(20)      >
#           output(:default)
#       end
#       Wukong::LocalRunner.receive(:flow => Wukong.dataflow(:integers))
#     }

#     it 'runs' do
#       subject.run(:default)
#       subject.flow.output(:default).records.should == %w[01 11 21 31 41 51 61 71 81 91 02 12 22 32 42 52 62 72 82 92]
#     end

#   end
# end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
wukong-3.0.0.pre3	spec/wukong/local_runner_spec.rb
wukong-3.0.0.pre2	spec/wukong/local_runner_spec.rb