class Listen::Event::Queue
def <<(args)
def <<(args) type, change, dir, path, options = *args fail "Invalid type: #{type.inspect}" unless [:dir, :file].include? type fail "Invalid change: #{change.inspect}" unless change.is_a?(Symbol) fail "Invalid path: #{path.inspect}" unless path.is_a?(String) dir = if @config.relative? _safe_relative_from_cwd(dir) else dir end @event_queue << [type, change, dir, path, options] end
def _safe_relative_from_cwd(dir)
def _safe_relative_from_cwd(dir) dir.relative_path_from(Pathname.pwd) rescue ArgumentError dir end
def initialize(config)
def initialize(config) @event_queue = ::Queue.new @config = config end