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