Sha256: f25b8c08c7f9afc8174daa044eb92a4dc3d8ff6035ebbdcc73299ef4b15ccbc8
Contents?: true
Size: 549 Bytes
Versions: 121
Compression:
Stored size: 549 Bytes
Contents
require "#{File.dirname(__FILE__)}/../dataflow"
include Dataflow
local do |stream, doubles, triples, squares|
unify stream, Array.new(5) { Dataflow::Variable.new }
Thread.new { unify doubles, stream.map {|n| n*2 } }
Thread.new { unify triples, stream.map {|n| n*3 } }
Thread.new { unify squares, stream.map {|n| n**2 } }
Thread.new { stream.each {|x| unify x, rand(100) } }
puts "original: #{stream.inspect}"
puts "doubles: #{doubles.inspect}"
puts "triples: #{triples.inspect}"
puts "squares: #{squares.inspect}"
end
Version data entries
121 entries across 121 versions & 3 rubygems