Sha256: bda04a737b00c940cf599673cb07cfad8c997c81a75cfa0869b2457256b12e42
Contents?: true
Size: 576 Bytes
Versions: 55
Compression:
Stored size: 576 Bytes
Contents
module EY
module Serverside
$LOAD_PATH.unshift File.expand_path('../../vendor/celluloid/lib', File.dirname(__FILE__))
require 'celluloid'
class Future
def self.call(servers, *args, &block)
futures = servers.map do |server|
new(server, *args, &block)
end
futures.each {|f| f.call}
futures
end
def future
Celluloid::Future.new(@server, *@args, &@block)
end
def call
# Celluloid needs to call the block explicitely
@value ||= future.call
end
end
end
end
Version data entries
55 entries across 55 versions & 1 rubygems