Class: Arrow::RecordBatchStreamReader

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

Instance Method Summary collapse

Instance Method Details

#each ⇒ Object 



22
23
24
25
26
27
28
29
30
 
# File 'lib/arrow/record-batch-stream-reader.rb', line 22

def each
  return to_enum(__method__) unless block_given?

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