Class: Invoker::Reactor
- Inherits:
-
Object
- Object
- Invoker::Reactor
- Defined in:
- lib/invoker/reactor.rb
Defined Under Namespace
Classes: Reader
Instance Attribute Summary collapse
-
#reader ⇒ Object
Returns the value of attribute reader.
Instance Method Summary collapse
-
#initialize ⇒ Reactor
constructor
A new instance of Reactor.
- #monitor_for_fd_events ⇒ Object
-
#send_data(socket, data) ⇒ Object
Writes data to client socket and raises error if errors while writing.
- #watch_for_read(fd) ⇒ Object
Constructor Details
Instance Attribute Details
#reader ⇒ Object
Returns the value of attribute reader.
3 4 5 |
# File 'lib/invoker/reactor.rb', line 3 def reader @reader end |
Instance Method Details
#monitor_for_fd_events ⇒ Object
21 22 23 24 25 26 27 |
# File 'lib/invoker/reactor.rb', line 21 def monitor_for_fd_events ready_read_fds, _ , _ = select(*) if ready_read_fds && !ready_read_fds.empty? reader.handle_read_event(ready_read_fds) end end |
#send_data(socket, data) ⇒ Object
Writes data to client socket and raises error if errors while writing
15 16 17 18 19 |
# File 'lib/invoker/reactor.rb', line 15 def send_data(socket, data) socket.write(data) rescue raise Invoker::Errors::ClientDisconnected end |
#watch_for_read(fd) ⇒ Object
9 10 11 |
# File 'lib/invoker/reactor.rb', line 9 def watch_for_read(fd) reader.watch_for_read(fd) end |