Sha256: 4c5088996d8dfe0aff004df257828970b1286e5ee4140d200c3d559fd66391da
Contents?: true
Size: 1.12 KB
Versions: 96
Compression:
Stored size: 1.12 KB
Contents
# frozen_string_literal: true
module Listen
class Listener
class Config
DEFAULTS = {
# Listener options
debug: false, # TODO: is this broken?
wait_for_delay: nil, # NOTE: should be provided by adapter if possible
relative: false,
# Backend selecting options
force_polling: false,
polling_fallback_message: nil
}.freeze
def initialize(opts)
@options = DEFAULTS.merge(opts)
@relative = @options[:relative]
@min_delay_between_events = @options[:wait_for_delay]
@silencer_rules = @options # silencer will extract what it needs
end
def relative?
@relative
end
attr_reader :min_delay_between_events, :silencer_rules
def adapter_instance_options(klass)
valid_keys = klass.const_get('DEFAULTS').keys
Hash[@options.select { |key, _| valid_keys.include?(key) }]
end
def adapter_select_options
valid_keys = %w[force_polling polling_fallback_message].map(&:to_sym)
Hash[@options.select { |key, _| valid_keys.include?(key) }]
end
end
end
end
Version data entries
96 entries across 95 versions & 6 rubygems