Module: EMRPC::Em2Rev
- Defined in:
- lib/emrpc/util/em2rev.rb
Overview
Wraps eventmachine protocol module with Rev socket callbacks
Class Method Summary collapse
Instance Method Summary collapse
- #initialize(*args, &blk) ⇒ Object
- #on_close ⇒ Object
- #on_connect ⇒ Object
- #on_connect_failed ⇒ Object
- #on_read(data) ⇒ Object
- #send_data(data) ⇒ Object
Class Method Details
.wrap(em_protocol) ⇒ Object
14 15 16 17 18 19 20 |
# File 'lib/emrpc/util/em2rev.rb', line 14 def self.wrap(em_protocol) wrapper = self Class.new(::Rev::TCPSocket) do include em_protocol include wrapper end end |
Instance Method Details
#initialize(*args, &blk) ⇒ Object
22 23 24 25 |
# File 'lib/emrpc/util/em2rev.rb', line 22 def initialize(*args, &blk) super(*args, &blk) post_init if respond_to?(:post_init) end |
#on_close ⇒ Object
31 32 33 |
# File 'lib/emrpc/util/em2rev.rb', line 31 def on_close unbind if respond_to?(:unbind) end |
#on_connect ⇒ Object
27 28 29 |
# File 'lib/emrpc/util/em2rev.rb', line 27 def on_connect connection_completed if respond_to?(:connection_completed) end |
#on_connect_failed ⇒ Object
35 36 37 |
# File 'lib/emrpc/util/em2rev.rb', line 35 def on_connect_failed unbind if respond_to?(:unbind) end |
#on_read(data) ⇒ Object
39 40 41 |
# File 'lib/emrpc/util/em2rev.rb', line 39 def on_read(data) receive_data(data) end |
#send_data(data) ⇒ Object
43 44 45 |
# File 'lib/emrpc/util/em2rev.rb', line 43 def send_data(data) write(data) end |