Module: Sequel::Postgres::Streaming

Defined in:

lib/sequel_pg/streaming.rb

Overview

Database methods necessary to support streaming. You should extend your Database object with this:

DB.extend Sequel::Postgres::Streaming

Then you can call #stream on your datasets to use the streaming support:

DB[:table].stream.each{|row| ...}

Defined Under Namespace

Modules: AllQueries, DatasetMethods

Class Method Summary

• .extended(db) ⇒ Object

  Also extend the database’s datasets to support streaming.

Class Method Details

.extended(db) ⇒ Object

Also extend the database’s datasets to support streaming

# File 'lib/sequel_pg/streaming.rb', line 18

def self.extended(db)
  db.extend_datasets(DatasetMethods)
end