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.2.0'
Class Method Summary
collapse
Class Method Details
.running? ⇒ 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
|