Sha256: 568525047a83485d038f82546fb2bb9dd9c124c6cdb1d59828830fff865b1430
Contents?: true
Size: 254 Bytes
Versions: 121
Compression:
Stored size: 254 Bytes
Contents
require "#{File.dirname(__FILE__)}/../dataflow"
include Dataflow
local do |port, stream|
unify port, Dataflow::Port.new(stream)
Thread.new {port.send 2}
Thread.new {port.send 8}
Thread.new {port.send 1024}
puts stream.take(3).sort.inspect
end
Version data entries
121 entries across 121 versions & 3 rubygems