Contents

require_relative './event'
require_relative './page'

module EsHttpClient

  class CaughtUpStream

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

    def subscribe(&block)
      loop do
        sleep 1
        @ref = fetch(@ref, &block)
      end
    end

    def fetch(ref, &block)
      response = @connection.get(ref.uri, ref.etag)
      page = Page.new(response.body)
      next_uri = ref.uri
      if page.has_entries?
        page.each_event(&block)
        next_uri = page.previous
      end
      return Ref.new(next_uri, response.headers['etag'])
    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/caught_up_stream.rb
es-http-client-0.1.2	lib/es_http_client/caught_up_stream.rb
es-http-client-0.1.1	lib/es_http_client/caught_up_stream.rb
es-http-client-0.1.0	lib/es_http_client/caught_up_stream.rb