Sha256: ba26c94a24cb4be30492cc9bd4a5686d122eb6d8c345524c16cb7488e82b5ec4
Contents?: true
Size: 535 Bytes
Versions: 1
Compression:
Stored size: 535 Bytes
Contents
require "eventmachine-tail" class Woodchuck::TailReader < EventMachine::FileTail attr_accessor :input_format, :output def self.static_init(input_format, output) @@input_format = input_format @@output = output end def initialize(path, startpos = -1) super(path, startpos) @input_format = @@input_format @output = @@output @buffer = BufferedTokenizer.new end def receive_data(data) @buffer.extract(data.force_encoding('utf-8')).each do |line| @output.handle(@input_format.create(path, line)) end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
woodchuck-json-event-0.0.2 | lib/woodchuck/tail_reader.rb |