Sha256: 6db1a067a370b9324ae9af4b9177378ed0403c9b5c1e3b199c45956d20afafa7
Contents?: true
Size: 539 Bytes
Versions: 12
Compression:
Stored size: 539 Bytes
Contents
module EY
module Serverside
$LOAD_PATH.unshift File.expand_path('../../vendor/dataflow', File.dirname(__FILE__))
require 'dataflow'
class Future
extend Dataflow
def self.call(blocks)
futures = map(blocks)
# Dataflow needs to call `barrier` and `need_later` in the same object
need_laters = futures.map do |future|
need_later { future.result }
end
barrier(*need_laters)
futures
end
def call
@block.call
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems