Class: MessageStore::Postgres::Get::Stream

Inherits:
Object
  • Object
show all
Includes:
MessageStore::Postgres::Get
Defined in:
lib/message_store/postgres/get/stream.rb,
lib/message_store/postgres/get/stream/last.rb

Defined Under Namespace

Classes: Last

Class Method Summary collapse

Instance Method Summary collapse

Methods included from MessageStore::Postgres::Get

build, call, configure, #configure, constrain_condition, #convert, #get_result, included, specialization

Class Method Details

.command_text(parameters) ⇒ Object 



7
8
9
 
# File 'lib/message_store/postgres/get/stream.rb', line 7

def self.command_text(parameters)
  "SELECT * FROM get_stream_messages(#{parameters});"
end

Instance Method Details

#last_position(batch) ⇒ Object 



11
12
13
 
# File 'lib/message_store/postgres/get/stream.rb', line 11

def last_position(batch)
  batch.last.position
end