Class: MessageStore::Postgres::Read

Inherits:
Object
  • Object
show all
Includes:
Read
Defined in:
lib/message_store/postgres/read.rb,
lib/message_store/postgres/read/iterator.rb

Defined Under Namespace

Classes: Iterator

Instance Method Summary collapse

Instance Method Details

#configure(session: nil, condition: nil) ⇒ Object 



6
7
8
9
 
# File 'lib/message_store/postgres/read.rb', line 6

def configure(session: nil, condition: nil)
  Iterator.configure(self, stream_name, position: position)
  Get.configure(self.iterator, batch_size: batch_size, condition: condition, session: session)
end