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

Defined in:
lib/rom/plugins/relation/sql/postgres/streaming.rb

Instance Method Summary collapse

Instance Method Details

#stream_each ⇒ Object 



91
92
93
94
95
96
97
 
# File 'lib/rom/plugins/relation/sql/postgres/streaming.rb', line 91

def stream_each
  return to_enum unless block_given?

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