Class: SequelMapper::AssociationProxy

Inherits:
Object
  • Object
show all
Includes:
Enumerable
Defined in:
lib/sequel_mapper/association_proxy.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(assoc_enum) ⇒ AssociationProxy

Returns a new instance of AssociationProxy.



5
6
7
8
9
 
# File 'lib/sequel_mapper/association_proxy.rb', line 5

def initialize(assoc_enum)
  @assoc_enum = assoc_enum
  @added_nodes = []
  @removed_nodes = []
end

Instance Attribute Details

#added_nodes ⇒ Object (readonly)

Returns the value of attribute added_nodes.



11
12
13
 
# File 'lib/sequel_mapper/association_proxy.rb', line 11

def added_nodes
  @added_nodes
end

#removed_nodes ⇒ Object (readonly)

Returns the value of attribute removed_nodes.



11
12
13
 
# File 'lib/sequel_mapper/association_proxy.rb', line 11

def removed_nodes
  @removed_nodes
end

Instance Method Details

#each(&block) ⇒ Object 



15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/sequel_mapper/association_proxy.rb', line 15

def each(&block)
  enum = Enumerator.new do |yielder|
    assoc_enum.each do |element|
      yielder.yield(element) unless removed?(element)
    end

    @added_nodes.each do |node|
      yielder.yield(node)
    end
  end

  if block
    enum.each(&block)
    self
  else
    enum
  end
end

#push(node) ⇒ Object 



39
40
41
 
# File 'lib/sequel_mapper/association_proxy.rb', line 39

def push(node)
  @added_nodes.push(node)
end

#remove(node) ⇒ Object 



34
35
36
37
 
# File 'lib/sequel_mapper/association_proxy.rb', line 34

def remove(node)
  @removed_nodes.push(node)
  self
end

#where(criteria) ⇒ Object 



43
44
45
46
 
# File 'lib/sequel_mapper/association_proxy.rb', line 43

def where(criteria)
  @assoc_enum.where(criteria)
  self
end