Gemfury - lib/event_store/consumer/controls/read.rb · eventide / event_store-consumer v0.3.2.3 - ruby package

eventide / event_store-consumer ruby

Repository URL to install this package:

Details

event_store-consumer / lib / event_store / consumer / controls / read.rb

module EventStore
  module Consumer
    module Controls
      module Read
        def self.call(stream_name, direction=nil, &action)
          reader = EventStore::Client::HTTP::Reader.build(
            stream_name,
            direction: direction,
            slice_size: 1
          )

          reader.each &action
        end
      end
    end
  end
end