Class: EnumerableInflater

Inherits:

Object

• Object
• EnumerableInflater

Defined in:

lib/fluent/plugin/enumerable_inflater.rb

Constant Summary

CHUNKSIZE =

1024**2

Instance Method Summary

• #initialize(options = {}) ⇒ EnumerableInflater constructor

  A new instance of EnumerableInflater.

• #lines ⇒ Object

Constructor Details

#initialize(options = {}) ⇒ EnumerableInflater

Returns a new instance of EnumerableInflater.

# File 'lib/fluent/plugin/enumerable_inflater.rb', line 8

def initialize(options = {})
  @io = options[:io]
end

Instance Method Details

#lines ⇒ Object

# File 'lib/fluent/plugin/enumerable_inflater.rb', line 12

def lines
  Enumerator.new { |main_enum| stream_lines(main_enum) }
end