Module: Dharma

Defined in:
lib/dharma.rb,
lib/dharma/future.rb,
lib/dharma/promise.rb,
lib/dharma/kept_promise.rb,
lib/dharma/inline_executor.rb,
lib/dharma/promise_actions.rb,
lib/dharma/thread_executor.rb

Defined Under Namespace

Modules: PromiseActions Classes: Future, IllegalStateException, InlineExecutor, KeptPromise, NoSuchElementException, Promise, PromiseFailure, ThreadExecutor, TimeoutException

Constant Summary collapse

VERSION = 
'0.9.1'

Class Method Summary collapse

Class Method Details

.default_executor ⇒ Object 



9
10
11
 
# File 'lib/dharma.rb', line 9

def self.default_executor
  @default_executor ||= Dharma::ThreadExecutor.new
end

.default_executor=(executor) ⇒ Object 



13
14
15
 
# File 'lib/dharma.rb', line 13

def self.default_executor=(executor)
  @default_executor = executor
end

.first_completed_of(promises) ⇒ Object 



35
36
37
38
39
40
41
42
43
 
# File 'lib/dharma.rb', line 35

def self.first_completed_of(promises)
  p = Dharma.promise
  promises.each do |promies|
    promise.on_complete do |value, as|
      p.try_complete(value, as)
    end
  end
  p
end

.future(executor = default_executor, &work) ⇒ Object 



21
22
23
 
# File 'lib/dharma.rb', line 21

def self.future(executor = default_executor, &work)
  Dharma::Future.call(work, executor)
end

.promise ⇒ Object 



17
18
19
 
# File 'lib/dharma.rb', line 17

def self.promise
  Dharma::Promise.new
end

.ready(promise, duration = nil) ⇒ Object 



51
52
53
 
# File 'lib/dharma.rb', line 51

def self.ready(promise, duration = nil)
  promise.ready(duration)
end

.result(promise, duration = nil) ⇒ Object 



55
56
57
 
# File 'lib/dharma.rb', line 55

def self.result(promise, duration = nil)
  promise.result(duration)
end

.sequence(promises) ⇒ Object 



25
26
27
28
29
30
31
32
33
 
# File 'lib/dharma.rb', line 25

def self.sequence(promises)
  if promises.is_a?(Array) && promises.length == 1
    return promises.first
  end

  future do
    promises.map { |p| p.result }
  end
end

.trace_completion(tag, promise, logger = Rails.logger) ⇒ Object 



45
46
47
48
49
 
# File 'lib/dharma.rb', line 45

def self.trace_completion(tag, promise, logger = Rails.logger)
  promise.on_complete do |value, as|
    logger.info "#{tag}: #{as}: #{value.inspect}"
  end
end