Contents

require_relative './readonly_stream'
require_relative './writeable_stream'

module EsHttpClient

  class Client

    def initialize(connection)
      @connection = connection
    end

    def stream(type, id)
      WriteableStream.new("#{type}-#{id}", @connection)
    end

    def all_events
      @all ||= ReadonlyStream.new("$all", @connection)
    end

  end

end

Version data entries

3 entries across 3 versions & 1 rubygems

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