Contents

require 'celluloid/io/version'

require 'forwardable'
require 'celluloid'
require 'celluloid/io/common_methods'
require 'celluloid/io/mailbox'
require 'celluloid/io/reactor'

require 'celluloid/io/tcp_server'
require 'celluloid/io/tcp_socket'
require 'celluloid/io/udp_socket'

module Celluloid
  # Actors with evented IO support
  module IO
    def self.included(klass)
      klass.send :include, Celluloid
      klass.use_mailbox Celluloid::IO::Mailbox
    end

    extend Forwardable

    # Wait for the given IO object to become readable/writeable
    def_delegators 'current_actor.mailbox.reactor', :wait_readable, :wait_writeable
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
celluloid-io-0.9.0	lib/celluloid/io.rb