# File lib/celluloid/call/block.rb, line 4 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/call/block.rb, line 12 def call @block_proxy.call end
# File lib/celluloid/call/block.rb, line 16 def dispatch response = @block_proxy.block.call(*@arguments) @sender << Internals::Response::Block.new(self, response) end