class FileWatch::ObservingRead

Public Instance Methods

subscribe(observer) click to toggle source
# File lib/filewatch/observing_read.rb, line 10
def subscribe(observer)
  # observer here is the file input
  watch.subscribe(observer, sincedb_collection)
  sincedb_collection.write("read mode subscribe complete - shutting down")
end

Private Instance Methods

build_specific_processor(settings) click to toggle source
# File lib/filewatch/observing_read.rb, line 18
def build_specific_processor(settings)
  ReadMode::Processor.new(settings)
end