module ROM::Plugins::Relation::SQL::Postgres::Streaming::Composite

Public Instance Methods

stream_each() { |call([tuple]).first| ... } click to toggle source
# File lib/rom/plugins/relation/sql/postgres/streaming.rb, line 88
def stream_each
  return to_enum unless block_given?

  left.stream_each do |tuple|
    yield right.call([tuple]).first
  end
end