Class: ZQ::Sources::IOSource

Inherits:

Object

Object
ZQ::Sources::IOSource

Includes:: NonTransactional

Defined in:: lib/zq/sources/io.rb

Instance Method Summary collapse

#initialize(file) ⇒ IOSource constructor

A new instance of IOSource.
#read_next ⇒ Object

Methods included from NonTransactional

#transactional?

Constructor Details

#initialize(file) ⇒ `IOSource`

Returns a new instance of IOSource.



5
6
7

# File 'lib/zq/sources/io.rb', line 5

def initialize file
  @file = file
end

Instance Method Details

#read_next ⇒ `Object`

# File 'lib/zq/sources/io.rb', line 9

def read_next
  begin
    @file.readline[0..-2]
  rescue EOFError
  end
end