class EsHttpClient::ReadonlyStream

Public Class Methods

new(stream_name, connection) click to toggle source
# File lib/es_http_client/readonly_stream.rb, line 10
def initialize(stream_name, connection)
  @stream_name = stream_name
  @connection = connection
end

Public Instance Methods

replay_forward(&block) click to toggle source
# File lib/es_http_client/readonly_stream.rb, line 15
def replay_forward(&block)
  ref = StreamEvents.new(@stream_name, @connection).each(&block)
  CaughtUpStream.new(ref, @connection)
end