Celluloid::IO & rb-inotify

celluloid-io-inotify.rb

require "celluloid/io"
require "rb-inotify"
require "forwardable"

module Celluloid
  module IO
    class INotify
      extend Forwardable
      def_delegators :@notifier, :watch, :close

      def initialize
        @notifier = ::INotify::Notifier.new
      end

      def wait_readable; Celluloid::IO.wait_readable(self); end
      def to_io; @notifier.to_io; end

      def process
        wait_readable
        @notifier.process
      end
    end
  end
end


class A
  include Celluloid::IO

  def initialize()
    @notifier = INotify.new
    @notifier.watch("/tmp/a", :all_events) { |e|
      puts "#{e} from /tmp/a"
    }
  end

  def test
    @notifier.process
  end
end


A.new.test