Module: Tribe::EM

Defined in:
lib/tribe_em.rb,
lib/tribe_em/version.rb,
lib/tribe_em/connection.rb,
lib/tribe_em/tcp_server.rb,
lib/tribe_em/actor_proxy.rb,
lib/tribe_em/dedicated_connection.rb

Defined Under Namespace

Classes: ActorProxy, Connection, DedicatedConnection, TcpServer

Constant Summary collapse

VERSION = 
'0.4.0'

Class Method Summary collapse

Class Method Details

.running? ⇒ Boolean

Returns:

  • (Boolean) 


35
36
37
 
# File 'lib/tribe_em.rb', line 35

def self.running?
  return ::EM.reactor_running?
end

.start ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
24
25
 
# File 'lib/tribe_em.rb', line 12

def self.start
  @em_thread = Thread.new do
    ::EM.run do
      ::EM.kqueue = true if ::EM.kqueue?
      ::EM.epoll = true if ::EM.epoll?

      ::EM.error_handler do |e|
        puts "EXCEPTION: #{e.message}\n#{e.backtrace.join("\n")}--"
      end
    end
  end

  return nil
end

.stop ⇒ Object 



27
28
29
30
31
32
33
 
# File 'lib/tribe_em.rb', line 27

def self.stop
  ::EM.stop_event_loop
  @em_thread.join if @em_thread
  @em_thread = nil

  return nil
end