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