Method: Arrow::RecordBatchStreamReader#each

Defined in:
lib/arrow/record-batch-stream-reader.rb

#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