Celluloid::IO

Actors with evented IO support

Constants

VERSION

Public Class Methods

evented?() click to toggle source
# 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) click to toggle source
# File lib/celluloid/io.rb, line 21
def self.included(klass)
  klass.send :include, Celluloid
  klass.mailbox_class Celluloid::IO::Mailbox
end
wait_readable(io) click to toggle source
# File lib/celluloid/io.rb, line 31
def wait_readable(io)
  io = io.to_io
  if IO.evented?
    mailbox = Thread.current[:celluloid_mailbox]
    mailbox.reactor.wait_readable(io)
  else
    Kernel.select([io])
  end
  nil
end
wait_writable(io) click to toggle source
# File lib/celluloid/io.rb, line 43
def wait_writable(io)
  io = io.to_io
  if IO.evented?
    mailbox = Thread.current[:celluloid_mailbox]
    mailbox.reactor.wait_writable(io)
  else
    Kernel.select([], [io])
  end
  nil
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.