Sha256: a6504c92b2f6c0ee9aa2310ea84e8811c7020b5e49a0581962ccbd1bdf169413

Contents?: true

Size: 295 Bytes

Versions: 3

Compression:

Stored size: 295 Bytes

Contents

require 'pb_actor/future'
require 'securerandom'

module PbActor
  class FutureProxy < BasicProxy
    def method_missing method, *args, &blk
      super
      id = SecureRandom.uuid
      Message.send [:future_method_call, id, method, *args], @wr
      Future.new id, @wr, @rd
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
pb_actor-0.0.5 lib/pb_actor/future_proxy.rb
pb_actor-0.0.4 lib/pb_actor/future_proxy.rb
pb_actor-0.0.3 lib/pb_actor/future_proxy.rb