class React::State
Attributes
current_observer[R]
Public Class Methods
get_state(object, name, current_observer = @current_observer)
click to toggle source
# File lib/react/state.rb, line 46 def get_state(object, name, current_observer = @current_observer) # get current value of name for object, remember that the current object depends on this state, # current observer can be overriden with last param new_observers[current_observer][object] << name if current_observer && !new_observers[current_observer][object].include?(name) states[object][name] end
initialize_states(object, initial_values)
click to toggle source
# File lib/react/state.rb, line 42 def initialize_states(object, initial_values) # initialize objects' name/value pairs states[object].merge!(initial_values || {}) end
is_observing?(object, name, current_observer)
click to toggle source
# File lib/react/state.rb, line 86 def is_observing?(object, name, current_observer) current_observer && observers_by_name[object][name].include?(current_observer) end
notify_observers(object, name, value)
click to toggle source
# File lib/react/state.rb, line 63 def notify_observers(object, name, value) object_needs_notification = object.respond_to? :update_react_js_state observers_by_name[object][name].dup.each do |observer| observer.update_react_js_state(object, name, value) object_needs_notification = false if object == observer end object.update_react_js_state(nil, name, value) if object_needs_notification end
notify_observers_after_thread_completes(object, name, value)
click to toggle source
# File lib/react/state.rb, line 72 def notify_observers_after_thread_completes(object, name, value) (@delayed_updates ||= []) << [object, name, value] @delayed_updater ||= after(0) do delayed_updates = @delayed_updates @delayed_updates = [] @delayed_updater = nil delayed_updates.each { |args| notify_observers(*args) } end end
remove()
click to toggle source
# File lib/react/state.rb, line 106 def remove # call after component is unmounted raise "remove called outside of watch block" unless @current_observer current_observers[@current_observer].each do |object, names| names.each do |name| observers_by_name[object][name].delete(@current_observer) end end current_observers.delete(@current_observer) end
set_state(object, name, value, wait_till_thread_completes = nil)
click to toggle source
# File lib/react/state.rb, line 53 def set_state(object, name, value, wait_till_thread_completes = nil) states[object][name] = value if wait_till_thread_completes notify_observers_after_thread_completes(object, name, value) elsif @rendering_level == 0 notify_observers(object, name, value) end value end
set_state_context_to(observer, rendering = nil) { || ... }
click to toggle source
# File lib/react/state.rb, line 116 def set_state_context_to(observer, rendering = nil) # wrap all execution that may set or get states in a block so we know which observer is executing if `typeof window.reactive_ruby_timing !== 'undefined'` @nesting_level = (@nesting_level || 0) + 1 start_time = Time.now.to_f observer_name = (observer.class.respond_to?(:name) ? observer.class.name : observer.to_s) rescue "object:#{observer.object_id}" end saved_current_observer = @current_observer @current_observer = observer @rendering_level += 1 if rendering return_value = yield return_value ensure @current_observer = saved_current_observer @rendering_level -= 1 if rendering @nesting_level = [0, @nesting_level - 1].max if `typeof window.reactive_ruby_timing !== 'undefined'` return_value end
states()
click to toggle source
# File lib/react/state.rb, line 134 def states @states ||= Hash.new { |h, k| h[k] = {} } end
update_states_to_observe(current_observer = @current_observer)
click to toggle source
# File lib/react/state.rb, line 90 def update_states_to_observe(current_observer = @current_observer) # should be called after the last after_render callback, currently called after components render method raise "update_states_to_observer called outside of watch block" unless current_observer current_observers[current_observer].each do |object, names| names.each do |name| observers_by_name[object][name].delete(current_observer) end end observers = current_observers[current_observer] = new_observers[current_observer] new_observers.delete(current_observer) observers.each do |object, names| names.each do |name| observers_by_name[object][name] << current_observer end end end
will_be_observing?(object, name, current_observer)
click to toggle source
# File lib/react/state.rb, line 82 def will_be_observing?(object, name, current_observer) current_observer && new_observers[current_observer][object].include?(name) end