Class: Reacto::Subscriptions::BufferedSubscription

Inherits:
SimpleSubscription show all
Includes:
Subscription
Defined in:
lib/reacto/subscriptions/buffered_subscription.rb

Instance Attribute Summary collapse

Attributes inherited from SimpleSubscription

#subscriptions

Instance Method Summary collapse

Methods included from Subscription

#add, #add_resource, #subscribed?, #unsubscribe

Methods inherited from SimpleSubscription

#add, #add_resource, #on_close, #on_error, #on_open, #on_value, #subscribed?, #unsubscribe

Constructor Details

#initialize(parent) ⇒ BufferedSubscription

Returns a new instance of BufferedSubscription.



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'lib/reacto/subscriptions/buffered_subscription.rb', line 8

def initialize(parent)
  @parent = parent
  @closed = false
  @active = false

  @buffer = Hash.new(NO_VALUE)
  @current_index = 0
  @last_error = nil

  open = lambda do
    @active = true
    @parent.on_open
  end

  value = lambda do |v|
    @buffer[@current_index] = v
    @current_index += 1

    @parent.on_value(v)
  end

  error = lambda do |e|
    @last_error = e
    @parent.on_error(e)
  end

  close = lambda do
    @closed = true
    @parent.on_close
  end

  super(open: open, value: value, error: error, close: close)
end

Instance Attribute Details

#buffer ⇒ Object

Returns the value of attribute buffer.



6
7
8
 
# File 'lib/reacto/subscriptions/buffered_subscription.rb', line 6

def buffer
  @buffer
end

#current_index ⇒ Object

Returns the value of attribute current_index.



6
7
8
 
# File 'lib/reacto/subscriptions/buffered_subscription.rb', line 6

def current_index
  @current_index
end

#last_error ⇒ Object

Returns the value of attribute last_error.



6
7
8
 
# File 'lib/reacto/subscriptions/buffered_subscription.rb', line 6

def last_error
  @last_error
end

Instance Method Details

#active? ⇒ Boolean

Returns:

  • (Boolean) 


42
43
44
 
# File 'lib/reacto/subscriptions/buffered_subscription.rb', line 42

def active?
  @active
end

#closed? ⇒ Boolean

Returns:

  • (Boolean) 


46
47
48
 
# File 'lib/reacto/subscriptions/buffered_subscription.rb', line 46

def closed?
  @closed
end