Class: Arrow::StreamReader

Inherits:
Object
  • Object
show all
Includes:
Enumerable
Defined in:
lib/arrow/stream-reader.rb

Instance Method Summary collapse

Instance Method Details

#each ⇒ Object 



19
20
21
22
23
24
25
 
# File 'lib/arrow/stream-reader.rb', line 19

def each
  loop do
    record_batch = next_record_batch
    break if record_batch.nil?
    yield(record_batch)
  end
end