Module: Glimmer::DataBinding::ObservableArray

Includes:
Observable
Defined in:
lib/glimmer/data_binding/observable_array.rb

Defined Under Namespace

Classes: Notifier

Instance Method Summary collapse

Methods included from Observable

#inspect

Instance Method Details

#<<(element) ⇒ Object Also known as: push, append 



154
155
156
157
158
159
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 154

def <<(element)
  super(element).tap do
    add_element_observers(element)
    notify_observers
  end
end

#[]=(index, value) ⇒ Object 



163
164
165
166
167
168
169
170
171
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 163

def []=(index, value)
  old_value = self[index]
  unregister_dependent_observers(old_value)
  remove_element_observers(old_value)
  add_element_observers(value)
  super(index, value).tap do
    notify_observers
  end
end

#add_element_observer(element, observer, options = {}) ⇒ Object 



69
70
71
72
73
74
75
76
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 69

def add_element_observer(element, observer, options = {})
  element_properties_for(observer).each do |property|
    observer.observe(element, property, options)
  end
  if element.is_a?(Array) && (options[:recursive] == true || (options[:recursive].is_a?(Integer) && options[:recursive] >= 0))
    ensure_array_object_observer(element, options)
  end
end

#add_element_observers(element, general_options = {}) ⇒ Object 



63
64
65
66
67
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 63

def add_element_observers(element, general_options = {})
  property_observer_list.each do |observer, options|
    add_element_observer(element, observer, options.merge(general_options))
  end
end

#add_observer(observer, *args) ⇒ Object 



48
49
50
51
52
53
54
55
56
57
58
59
60
61
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 48

def add_observer(observer, *args)
  options = args.last.is_a?(Hash) ? args.pop : {}
  element_properties = args
  element_properties = element_properties.flatten.compact.uniq
  return observer if has_observer?(observer) && has_observer_element_properties?(observer, element_properties)
  property_observer_list[observer] = options
  observer_element_properties[observer] = element_properties_for(observer) + Concurrent::Set.new(element_properties)
  if !options.empty? && options[:recursive].is_a?(Integer)
    options = options.clone
    options[:recursive] = options[:recursive] - 1
  end
  each { |element| add_element_observer(element, observer, options) }
  observer
end

#array_object_observer_for(object) ⇒ Object 



88
89
90
91
92
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 88

def array_object_observer_for(object)
  @array_object_observers ||= Concurrent::Hash.new
  @array_object_observers[object] = Notifier.new(self) unless @array_object_observers.has_key?(object)
  @array_object_observers[object]
end

#clear ⇒ Object 



223
224
225
226
227
228
229
230
231
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 223

def clear
  each do |old_value|
    unregister_dependent_observers(old_value)
    remove_element_observers(old_value)
  end
  super.tap do
    notify_observers
  end
end

#collect!(&block) ⇒ Object Also known as: map! 



239
240
241
242
243
244
245
246
247
248
249
250
251
252
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 239

def collect!(&block)
  if block_given?
    each do |old_value|
      unregister_dependent_observers(old_value)
      remove_element_observers(old_value)
    end
    super(&block).tap do
      each { |element| add_element_observers(element) }
      notify_observers
    end
  else
    super
  end
end

#compact! ⇒ Object 



255
256
257
258
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 255

def compact!
  # TODO consider checking which exact indices changed and only notifying if there is a change
  super.tap { notify_observers }
end

#delete(element) ⇒ Object 



191
192
193
194
195
196
197
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 191

def delete(element)
  unregister_dependent_observers(element)
  remove_element_observers(element)
  super(element).tap do
    notify_observers
  end
end

#delete_at(index) ⇒ Object 



199
200
201
202
203
204
205
206
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 199

def delete_at(index)
  old_value = self[index]
  unregister_dependent_observers(old_value)
  remove_element_observers(old_value)
  super(index).tap do
    notify_observers
  end
end

#delete_if(&block) ⇒ Object 



208
209
210
211
212
213
214
215
216
217
218
219
220
221
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 208

def delete_if(&block)
  if block_given?
    old_array = Array.new(self)
    super(&block).tap do |new_array|
      (old_array - new_array).each do |element|
        unregister_dependent_observers(element)
        remove_element_observers(element)
      end
      notify_observers
    end
  else
    super
  end
end

#element_properties_for(observer) ⇒ Object 



146
147
148
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 146

def element_properties_for(observer)
  observer_element_properties[observer] ||= Concurrent::Set.new
end

#ensure_array_object_observer(object, options) ⇒ Object 



78
79
80
81
82
83
84
85
86
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 78

def ensure_array_object_observer(object, options)
  return unless object&.is_a?(Array)
  array_object_observer = array_object_observer_for(object)
  array_observer_registration = array_object_observer.observe(object, options)
  property_observer_list.each do |observer, options|
    my_registration = observer.registration_for(self)
    observer.add_dependent(my_registration => array_observer_registration)
  end
end

#filter!(&block) ⇒ Object 



290
291
292
293
294
295
296
297
298
299
300
301
302
303
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 290

def filter!(&block)
  if block_given?
    old_array = Array.new(self)
    super(&block).tap do
      (old_array - self).each do |old_value|
        unregister_dependent_observers(old_value)
        remove_element_observers(old_value)
      end
      notify_observers
    end
  else
    super
  end
end

#flatten!(level = nil) ⇒ Object 



260
261
262
263
264
265
266
267
268
269
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 260

def flatten!(level=nil)
  each do |old_value|
    unregister_dependent_observers(old_value)
    remove_element_observers(old_value)
  end
  (level.nil? ? super() : super(level)).tap do
    each { |element| add_element_observers(element) }
    notify_observers
  end
end

#has_observer?(observer) ⇒ Boolean

Returns:

  • (Boolean) 


130
131
132
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 130

def has_observer?(observer)
  property_observer_list.keys.include?(observer)
end

#has_observer_element_properties?(observer, element_properties) ⇒ Boolean

Returns:

  • (Boolean) 


134
135
136
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 134

def has_observer_element_properties?(observer, element_properties)
  element_properties_for(observer).to_a.include_all?(*element_properties)
end

#notify_observers ⇒ Object 



150
151
152
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 150

def notify_observers
  property_observer_list.to_a.each { |obs, opt| obs.call(self) }
end

#observer_element_properties ⇒ Object 



142
143
144
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 142

def observer_element_properties
  @observer_element_properties ||= Concurrent::Hash.new
end

#pop ⇒ Object 



173
174
175
176
177
178
179
180
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 173

def pop
  popped_element = last
  unregister_dependent_observers(popped_element)
  remove_element_observers(popped_element)
  super.tap do
    notify_observers
  end
end

#property_observer_list ⇒ Object 



138
139
140
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 138

def property_observer_list
  @property_observer_list ||= Concurrent::Hash.new
end

#reject!(&block) ⇒ Object 



347
348
349
350
351
352
353
354
355
356
357
358
359
360
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 347

def reject!(&block)
  if block.nil?
    super
  else
    old_array = Array.new(self)
    super(&block).tap do
      (old_array - self).each do |old_value|
        unregister_dependent_observers(old_value)
        remove_element_observers(old_value)
      end
      notify_observers
    end
  end
end

#remove_element_observer(element, observer) ⇒ Object 



117
118
119
120
121
122
123
124
125
126
127
128
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 117

def remove_element_observer(element, observer)
  element_properties_for(observer).each do |property|
    observer.unobserve(element, property)
  end
  if element.is_a?(ObservableArray)
    array_object_observer_for(element).unobserve(element)
    element.property_observer_list.select {|obs, opt| obs.respond_to?(:observable_array) && obs.observable_array == self}.each do |o|
      o.deregister_all_observables if o.respond_to?(:deregister_all_observables)
      @array_object_observers.reject! {|k, v| v == o}
    end
  end
end

#remove_element_observers(element) ⇒ Object 



111
112
113
114
115
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 111

def remove_element_observers(element)
  property_observer_list.each do |observer, options|
    remove_element_observer(element, observer)
  end
end

#remove_observer(observer, *args) ⇒ Object 



94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 94

def remove_observer(observer, *args)
  options = args.last.is_a?(Hash) ? args.pop : {}
  element_properties = args
  element_properties = element_properties.flatten.compact.uniq
  if !element_properties.empty?
    old_element_properties = element_properties_for(observer)
    observer_element_properties[observer] = element_properties_for(observer) - Concurrent::Set.new(element_properties)
    each { |element| element_properties.each { |property| observer.unobserve(element, property) } }
  end
  if element_properties_for(observer).empty?
    property_observer_list.delete(observer)
    observer_element_properties.delete(observer)
    each { |element| remove_element_observer(element, observer) }
  end
  observer
end

#replace(other_array) ⇒ Object 



362
363
364
365
366
367
368
369
370
371
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 362

def replace(other_array)
  old_array = Array.new(self)
  super(other_array).tap do
    (old_array - self).each do |old_value|
      unregister_dependent_observers(old_value)
      remove_element_observers(old_value)
    end
    notify_observers
  end
end

#reverse! ⇒ Object 



233
234
235
236
237
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 233

def reverse!
  super.tap do
    notify_observers
  end
end

#rotate!(count = 1) ⇒ Object 



271
272
273
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 271

def rotate!(count=1)
  super(count).tap { notify_observers }
end

#select!(&block) ⇒ Object 



275
276
277
278
279
280
281
282
283
284
285
286
287
288
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 275

def select!(&block)
  if block_given?
    old_array = Array.new(self)
    super(&block).tap do
      (old_array - self).each do |old_value|
        unregister_dependent_observers(old_value)
        remove_element_observers(old_value)
      end
      notify_observers
    end
  else
    super
  end
end

#shift ⇒ Object 



182
183
184
185
186
187
188
189
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 182

def shift
  shifted_element = first
  unregister_dependent_observers(shifted_element)
  remove_element_observers(shifted_element)
  super.tap do
    notify_observers
  end
end

#shuffle!(hash = nil) ⇒ Object 



305
306
307
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 305

def shuffle!(hash = nil)
  (hash.nil? ? super() : super(random: hash[:random])).tap { notify_observers }
end

#slice!(arg1, arg2 = nil) ⇒ Object 



309
310
311
312
313
314
315
316
317
318
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 309

def slice!(arg1, arg2=nil)
  old_array = Array.new(self)
  (arg2.nil? ? super(arg1) : super(arg1, arg2)).tap do
    (old_array - self).each do |old_value|
      unregister_dependent_observers(old_value)
      remove_element_observers(old_value)
    end
    notify_observers
  end
end

#sort!(&block) ⇒ Object 



320
321
322
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 320

def sort!(&block)
  (block.nil? ? super() : super(&block)).tap { notify_observers }
end

#sort_by!(&block) ⇒ Object 



324
325
326
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 324

def sort_by!(&block)
  (block.nil? ? super() : super(&block)).tap { notify_observers }
end

#uniq!(&block) ⇒ Object 



328
329
330
331
332
333
334
335
336
337
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 328

def uniq!(&block)
  each do |old_value|
    unregister_dependent_observers(old_value)
    remove_element_observers(old_value)
  end
  (block.nil? ? super() : super(&block)).tap do
    each { |element| add_element_observers(element) }
    notify_observers
  end
end

#unregister_dependent_observers(old_value) ⇒ Object Also known as: deregister_dependent_observers 



373
374
375
376
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 373

def unregister_dependent_observers(old_value)
  return unless old_value.is_a?(ObservableModel) || old_value.is_a?(ObservableArray)
  property_observer_list.each { |observer, options| observer.unregister_dependents_with_observable(observer.registration_for(self), old_value) }
end

#unshift(element) ⇒ Object Also known as: prepend 



339
340
341
342
343
344
 
# File 'lib/glimmer/data_binding/observable_array.rb', line 339

def unshift(element)
  super(element).tap do
    add_element_observers(element)
    notify_observers
  end
end