class LogStash::Inputs::File::Reader

Public Class Methods

new(path, receiver) click to toggle source
Calls superclass method
# File lib/logstash/inputs/file.rb, line 40
def initialize(path, receiver)
  super(path)
  @receiver = receiver
  @buffer = BufferedTokenizer.new  # From eventmachine
end

Public Instance Methods

receive_data(data) click to toggle source
# File lib/logstash/inputs/file.rb, line 46
def receive_data(data)
  # TODO(2.0): Support multiline log data
  @buffer.extract(data).each do |line|
    @receiver.receive(self, line)
  end
end