Class: EventMachine::Synchrony::Multi
- Inherits:
-
Object
- Object
- EventMachine::Synchrony::Multi
- Includes:
- Deferrable
- Defined in:
- lib/em-synchrony/em-multi.rb
Instance Attribute Summary collapse
-
#requests ⇒ Object
readonly
Returns the value of attribute requests.
-
#responses ⇒ Object
readonly
Returns the value of attribute responses.
Instance Method Summary collapse
- #add(name, conn) ⇒ Object
- #finished? ⇒ Boolean
-
#initialize ⇒ Multi
constructor
A new instance of Multi.
- #perform ⇒ Object
Constructor Details
#initialize ⇒ Multi
Returns a new instance of Multi.
8 9 10 11 |
# File 'lib/em-synchrony/em-multi.rb', line 8 def initialize @requests = [] @responses = {:callback => {}, :errback => {}} end |
Instance Attribute Details
#requests ⇒ Object (readonly)
Returns the value of attribute requests.
6 7 8 |
# File 'lib/em-synchrony/em-multi.rb', line 6 def requests @requests end |
#responses ⇒ Object (readonly)
Returns the value of attribute responses.
6 7 8 |
# File 'lib/em-synchrony/em-multi.rb', line 6 def responses @responses end |
Instance Method Details
#add(name, conn) ⇒ Object
13 14 15 16 17 18 19 |
# File 'lib/em-synchrony/em-multi.rb', line 13 def add(name, conn) fiber = Fiber.current conn.callback { @responses[:callback][name] = conn; check_progress(fiber) } conn.errback { @responses[:errback][name] = conn; check_progress(fiber) } @requests.push(conn) end |
#finished? ⇒ Boolean
21 22 23 |
# File 'lib/em-synchrony/em-multi.rb', line 21 def finished? (@responses[:callback].size + @responses[:errback].size) == @requests.size end |
#perform ⇒ Object
25 26 27 |
# File 'lib/em-synchrony/em-multi.rb', line 25 def perform Fiber.yield unless finished? end |