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

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