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