Sha256: 169d5de9392b32a95d4c154df7ee8421a7c29dec162ed730dd5d77ff53fe6a34
Contents?: true
Size: 599 Bytes
Versions: 19
Compression:
Stored size: 599 Bytes
Contents
module EventSource
module Postgres
module Controls
module Put
def self.call(instances: nil, stream_name: nil, event: nil, category: nil)
instances ||= 1
stream_name ||= StreamName.example(category: category)
event_specified = !event.nil?
event ||= EventData::Write.example
instances.times do
EventSource::Postgres::Put.(event, stream_name)
unless event_specified
event.id = EventData::Write.id
end
end
stream_name
end
end
end
end
end
Version data entries
19 entries across 19 versions & 1 rubygems