Class: WampClient::Transport::EventMachineBase

Inherits:
Base
  • Object
show all
Defined in:
lib/wamp_client/transport/event_machine_base.rb

Direct Known Subclasses

FayeWebSocket, WebSocketEventMachine

Instance Attribute Summary

Attributes inherited from Base

#connected, #headers, #protocol, #proxy, #serializer, #uri

Class Method Summary collapse

Methods inherited from Base

#add_timer, #connect, #connected?, #disconnect, #initialize, #on, #on_close, #on_error, #on_message, #on_open, #send_message

Constructor Details

This class inherits a constructor from WampClient::Transport::Base

Class Method Details

.add_timer(milliseconds, &callback) ⇒ Object 



45
46
47
48
49
50
 
# File 'lib/wamp_client/transport/event_machine_base.rb', line 45

def self.add_timer(milliseconds, &callback)
  delay = (milliseconds.to_f/1000.0).ceil
  EM.add_timer(delay) {
    callback.call
  }
end

.start_event_machine(&block) ⇒ Object 



35
36
37
38
39
 
# File 'lib/wamp_client/transport/event_machine_base.rb', line 35

def self.start_event_machine(&block)
  EM.run do
    block.call
  end
end

.stop_event_machine ⇒ Object 



41
42
43
 
# File 'lib/wamp_client/transport/event_machine_base.rb', line 41

def self.stop_event_machine
  EM.stop
end