Contents

require_relative './stream_events'
require_relative './caught_up_stream'
require_relative './event'
require_relative './ref'

module EsHttpClient

  class ReadonlyStream

    def initialize(stream_name, connection)
      @stream_name = stream_name
      @connection = connection
    end

    def replay_forward(&block)
      ref = StreamEvents.new(@stream_name, @connection).each(&block)
      CaughtUpStream.new(ref, @connection)
    end

  end

end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
es-http-client-0.2.0	lib/es_http_client/readonly_stream.rb
es-http-client-0.1.2	lib/es_http_client/readonly_stream.rb
es-http-client-0.1.1	lib/es_http_client/readonly_stream.rb
es-http-client-0.1.0	lib/es_http_client/readonly_stream.rb