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