Module: ReactiveRecord

Defined in:
lib/reactive_record/pry.rb,
lib/reactive_record/broadcast.rb,
lib/reactive_record/permissions.rb,
lib/reactive_record/scope_description.rb,
lib/reactive_record/server_data_cache.rb,
lib/reactive_record/active_record/reactive_record/base.rb,
lib/reactive_record/active_record/reactive_record/collection.rb,
lib/reactive_record/active_record/reactive_record/operations.rb,
lib/reactive_record/active_record/reactive_record/dummy_value.rb,
lib/reactive_record/active_record/reactive_record/column_types.rb,
lib/reactive_record/active_record/reactive_record/while_loading.rb,
lib/reactive_record/active_record/reactive_record/isomorphic_base.rb,
lib/reactive_record/active_record/reactive_record/scoped_collection.rb,
lib/reactive_record/active_record/reactive_record/unscoped_collection.rb,
lib/reactive_record/active_record/reactive_record/reactive_set_relationship_helpers.rb

Defined Under Namespace

Modules: Operations, Pry, ScopedCollection, UnscopedCollection Classes: AccessViolation, Base, Broadcast, Collection, ScopeDescription, ServerDataCache, WhileLoading

Class Method Summary collapse

Class Method Details

.check_loads_pending ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/reactive_record/active_record/reactive_record/while_loading.rb', line 34

def self.check_loads_pending
  if @loads_pending
    if Base.pending_fetches.count > 0
      true
    else  # this happens when for example loading foo.x results in somebody looking at foo.y while foo.y is still being loaded
      ReactiveRecord::WhileLoading.loaded_at Base.last_fetch_at
      ReactiveRecord::WhileLoading.quiet!
      false
    end
  end
end

.load(&block) ⇒ Object

will repeatedly execute the block until it is loaded immediately returns a promise that will resolve once the block is loaded



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/reactive_record/active_record/reactive_record/while_loading.rb', line 12

def self.load(&block)
  promise = Promise.new
  @load_stack ||= []
  @load_stack << @loads_pending
  @loads_pending = nil
  result = block.call.itself
  if @loads_pending
    @blocks_to_load ||= []
    @blocks_to_load << [Base.last_fetch_at, promise, block]
  else
    promise.resolve result
  end
  @loads_pending = @load_stack.pop
  promise
rescue Exception => e
  React::IsomorphicHelpers.log "ReactiveRecord.load exception raised during initial load: #{e}", :error
end

.loads_pending! ⇒ Object 



30
31
32
 
# File 'lib/reactive_record/active_record/reactive_record/while_loading.rb', line 30

def self.loads_pending!
  @loads_pending = true
end

.run_blocks_to_load(fetch_id, failure = nil) ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/reactive_record/active_record/reactive_record/while_loading.rb', line 46

def self.run_blocks_to_load(fetch_id, failure = nil)
  if @blocks_to_load
    blocks_to_load_now = @blocks_to_load.select { |data| data.first == fetch_id }
    @blocks_to_load = @blocks_to_load.reject { |data| data.first == fetch_id }
    @load_stack ||= []
    blocks_to_load_now.each do |data|
      id, promise, block = data
      @load_stack << @loads_pending
      @loads_pending = nil
      result = block.call(failure)
      if check_loads_pending and !failure
        @blocks_to_load << [Base.last_fetch_at, promise, block]
      else
        promise.resolve result
      end
      @loads_pending = @load_stack.pop
    end
  end
rescue Exception => e
  React::IsomorphicHelpers.log "ReactiveRecord.load exception raised during retry: #{e}", :error
end