Module: Peasant::NodeCallbacks

Included in:
Node
Defined in:
lib/peasant/node_callbacks.rb

Instance Method Summary collapse

Instance Method Details

#assign_callbacks_to(connection) ⇒ Object 



46
47
48
49
50
51
 
# File 'lib/peasant/node_callbacks.rb', line 46

def assign_callbacks_to connection
  connection.on_connect  &on_connect_cb
  connection.on_data     &on_data_cb
  connection.on_response &on_response_cb
  connection.on_finish   &on_finish_cb
end

#on_connect ⇒ Object 



32
33
 
# File 'lib/peasant/node_callbacks.rb', line 32

def on_connect
end

#on_connect_cb ⇒ Object 



10
11
12
 
# File 'lib/peasant/node_callbacks.rb', line 10

def on_connect_cb
  lambda { |node| on_connect }
end

#on_data(data) ⇒ Object 



35
36
37
 
# File 'lib/peasant/node_callbacks.rb', line 35

def on_data data
  data
end

#on_data_cb ⇒ Object 



14
15
16
 
# File 'lib/peasant/node_callbacks.rb', line 14

def on_data_cb
  lambda { |data| on_data(data) }
end

#on_finish ⇒ Object 



43
44
 
# File 'lib/peasant/node_callbacks.rb', line 43

def on_finish
end

#on_finish_cb ⇒ Object 



22
23
24
25
26
27
 
# File 'lib/peasant/node_callbacks.rb', line 22

def on_finish_cb
  lambda do |node|
    node.decrement_counter
    on_finish
  end
end

#on_response(response) ⇒ Object 



39
40
41
 
# File 'lib/peasant/node_callbacks.rb', line 39

def on_response response
  response
end

#on_response_cb ⇒ Object 



18
19
20
 
# File 'lib/peasant/node_callbacks.rb', line 18

def on_response_cb
  lambda { |node, response| on_response(response) }
end

#on_select ⇒ Object 



29
30
 
# File 'lib/peasant/node_callbacks.rb', line 29

def on_select
end

#on_select_cb ⇒ Object 



3
4
5
6
7
8
 
# File 'lib/peasant/node_callbacks.rb', line 3

def on_select_cb
  lambda do
    increment_counter
    on_select
  end
end