Class: ConcurrentRails::Promises

Inherits:
Object
  • Object
show all
Extended by:
Testing::TestingFuture
Includes:
Concurrent::Promises::FactoryMethods, DelayAdapter, FutureAdapter
Defined in:
lib/concurrent_rails/promises.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Testing::TestingFuture

future

Methods included from FutureAdapter

#future_on_rails

Methods included from DelayAdapter

#delay_on_rails

Constructor Details

#initialize(executor) ⇒ Promises 



12
13
14
 
# File 'lib/concurrent_rails/promises.rb', line 12

def initialize(executor)
  @executor = executor
end

Instance Attribute Details

#executor ⇒ Object (readonly)

Returns the value of attribute executor.



67
68
69
 
# File 'lib/concurrent_rails/promises.rb', line 67

def executor
  @executor
end

Instance Method Details

#touch ⇒ Object 



35
36
37
38
39
 
# File 'lib/concurrent_rails/promises.rb', line 35

def touch
  @instance = rails_wrapped { instance.touch }

  self
end

#wait(timeout = nil) ⇒ Object 



41
42
43
44
45
 
# File 'lib/concurrent_rails/promises.rb', line 41

def wait(timeout = nil)
  result = permit_concurrent_loads { instance.__send__(:wait_until_resolved, timeout) }

  timeout ? result : self
end