Contents

unless RUBY_VERSION >= "1.9.2"
  raise LoadError, "AsyncEngine requires Ruby version >= 1.9.2 (current version is #{RUBY_VERSION})"
end


require "asyncengine/uv_error.rb"
require "asyncengine/asyncengine_ext.so"
require "asyncengine/version.rb"
require "asyncengine/handle.rb"
require "asyncengine/timer.rb"
require "asyncengine/udp.rb"
require "asyncengine/tcp.rb"
require "asyncengine/utils.rb"
require "asyncengine/debug.rb"  # TODO: Temporal.

require "socket"


module AsyncEngine

  @_handles = {}
  @_procs = {}
  @_next_tick_procs = []
  @_call_from_other_thread_procs = []
  @_user_error_handler = nil
  @_exit_error = nil
  @_on_exit_procs = []

  def self.stop
    return false  unless check_status()

    if running_thread?
      next_tick { release_loop() }
    else
      call_from_other_thread { release_loop() }
    end
    true
  end

  def self.on_error pr=nil, &bl
    block = pr || bl
    raise ::ArgumentError, "no block given"  unless block.is_a? ::Proc

    @_user_error_handler = block
  end

  def self.unset_on_error
    @_user_error_handler = nil
  end

  def self.on_exit pr=nil, &bl
    block = pr || bl
    raise ::ArgumentError, "no block given"  unless block.is_a? ::Proc

    @_on_exit_procs << block
  end

  def self.unset_on_exit
    @_on_exit_procs.clear
  end


  class << self
    private :release_loop
    private :check_status
  end

end


# Let's allow AE.xxxxx usage.
AE = AsyncEngine

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
asyncengine-0.0.2.alpha1	lib/asyncengine.rb