Module: Reacto::Behaviours

Defined in:
lib/reacto/behaviours.rb

Class Method Summary collapse

Class Method Details

.array_repeat_enumerator(array) ⇒ Object 



38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/reacto/behaviours.rb', line 38

def array_repeat_enumerator(array)
  size = array.size

  Enumerator.new do |yielder|
    n = 0
    loop do
      yielder.yield array[n % size]
      n = n + 1
    end
  end
end

.integers_enumerator ⇒ Object 



28
29
30
31
32
33
34
35
36
 
# File 'lib/reacto/behaviours.rb', line 28

def integers_enumerator
  Enumerator.new do |yielder|
    n = 0
    loop do
      yielder.yield n
      n = n + 1
    end
  end
end

.single_tracker_value(tracker, value) ⇒ Object 



14
15
16
17
18
 
# File 'lib/reacto/behaviours.rb', line 14

def single_tracker_value(tracker, value)
  with_close_and_error(tracker) do |subscriber|
    subscriber.on_value(value) if subscriber.subscribed?
  end
end

.single_value(value) ⇒ Object 



20
21
22
23
24
25
26
 
# File 'lib/reacto/behaviours.rb', line 20

def single_value(value)
  lambda do |tracker|
    with_close_and_error(tracker) do |subscriber|
      subscriber.on_value(value) if subscriber.subscribed?
    end
  end
end

.with_close_and_error(tracker, &block) ⇒ Object 



5
6
7
8
9
10
11
12
 
# File 'lib/reacto/behaviours.rb', line 5

def with_close_and_error(tracker, &block)
  begin
    yield tracker if block_given?
    tracker.on_close if tracker.subscribed?
  rescue StandardError => error
    tracker.on_error(error) if tracker.subscribed?
  end
end