# File lib/celluloid/calls.rb, line 133 def initialize(block_proxy, sender, arguments, task = Thread.current[:celluloid_task]) @block_proxy = block_proxy @sender = sender @arguments = arguments @task = task end
# File lib/celluloid/calls.rb, line 141 def call @block_proxy.call end
# File lib/celluloid/calls.rb, line 145 def dispatch response = @block_proxy.block.call(*@arguments) @sender << BlockResponse.new(self, response) end