Repository URL to install this package:
|
Version:
0.3.2.3 ▾
|
module EventStore
module Consumer
module Controls
module Write
def self.call
stream_name = StreamName.example random: true
ending_position = Batch::FinalPosition.example
writer = EventStore::Client::HTTP::EventWriter.build
batch = (0..ending_position).map do |position|
EventData::Write.example position: position
end
writer.write batch, stream_name
stream_name
end
end
end
end
end