class Temporal::Testing::FutureRegistry

Attributes

store[R]

Public Class Methods

new() click to toggle source
# File lib/temporal/testing/future_registry.rb, line 4
def initialize
  @store = {}
end

Public Instance Methods

complete(token, result) click to toggle source
# File lib/temporal/testing/future_registry.rb, line 14
def complete(token, result)
  store[token].set(result)
end
fail(token, error) click to toggle source
# File lib/temporal/testing/future_registry.rb, line 18
def fail(token, error)
  store[token].fail(error)
end
register(token, future) click to toggle source
# File lib/temporal/testing/future_registry.rb, line 8
def register(token, future)
  raise 'already registered' if store.key?(token)

  store[token] = future
end