Contents

# A proxy which sends asynchronous calls to an actor
class Celluloid::Proxy::Async < Celluloid::Proxy::Abstract
  attr_reader :mailbox

  # Used for reflecting on proxy objects themselves
  def __class__
    ::Celluloid::Proxy::Async
  end

  def initialize(mailbox, klass)
    @mailbox = mailbox
    @klass = klass
  end

  def inspect
    "#<Celluloid::Proxy::Async(#{@klass})>"
  end

  def method_missing(meth, *args, &block)
    if @mailbox == ::Thread.current[:celluloid_mailbox]
      args.unshift meth
      meth = :__send__
    end
    if block_given?
      # FIXME: nicer exception
      fail "Cannot use blocks with async yet"
    end
    @mailbox << ::Celluloid::Call::Async.new(meth, args, block)
    self
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
celluloid-0.17.2	lib/celluloid/proxy/async.rb
celluloid-0.17.1.2	lib/celluloid/proxy/async.rb
celluloid-0.17.1.1	lib/celluloid/proxy/async.rb
celluloid-0.17.1	lib/celluloid/proxy/async.rb