module Consumer::Postgres::Controls::Position::Stream::Write

Public Class Methods

call(stream_name=nil, position: nil) click to toggle source
# File lib/consumer/postgres/controls/position/stream/write.rb, line 7
def self.call(stream_name=nil, position: nil)
  stream_name ||= Category::Position.example

  message = Store::Recorded.example(position: position)

  Messaging::Postgres::Write.(message, stream_name)

  stream_name
end