# File lib/celluloid/calls.rb, line 136 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 144 def call @block_proxy.call end
# File lib/celluloid/calls.rb, line 148 def dispatch response = @block_proxy.block.call(*@arguments) @sender << BlockResponse.new(self, response) end