Module: Celluloid::IO
- Defined in:
- lib/celluloid/io.rb,
lib/celluloid/io/stream.rb,
lib/celluloid/io/mailbox.rb,
lib/celluloid/io/reactor.rb,
lib/celluloid/io/version.rb,
lib/celluloid/io/ssl_server.rb,
lib/celluloid/io/ssl_socket.rb,
lib/celluloid/io/tcp_server.rb,
lib/celluloid/io/tcp_socket.rb,
lib/celluloid/io/udp_socket.rb,
lib/celluloid/io/unix_server.rb,
lib/celluloid/io/unix_socket.rb,
lib/celluloid/io/dns_resolver.rb
Overview
Actors with evented IO support
Defined Under Namespace
Classes: DNSResolver, Mailbox, Reactor, SSLServer, SSLSocket, Stream, TCPServer, TCPSocket, UDPSocket, UNIXServer, UNIXSocket
Constant Summary collapse
- VERSION =
"0.14.1"
Class Method Summary collapse
- .evented? ⇒ Boolean
- .included(klass) ⇒ Object
- .wait_readable(io) ⇒ Object
- .wait_writable(io) ⇒ Object
Class Method Details
.evented? ⇒ Boolean
26 27 28 29 |
# File 'lib/celluloid/io.rb', line 26 def self.evented? actor = Thread.current[:celluloid_actor] actor && actor.mailbox.is_a?(Celluloid::IO::Mailbox) end |
.included(klass) ⇒ Object
21 22 23 24 |
# File 'lib/celluloid/io.rb', line 21 def self.included(klass) klass.send :include, Celluloid klass.mailbox_class Celluloid::IO::Mailbox end |