Contents

module CouchRest
  class Streamer
    attr_accessor :db
    def initialize db
      @db = db
    end
    
    def view name, params = nil
      urlst = /^_/.match(name) ? "#{@db.root}/#{name}" : "#{@db.root}/_view/#{name}"
      url = CouchRest.paramify_url urlst, params
      IO.popen("curl --silent #{url}") do |view|
        view.gets # discard header
        while row = parse_line(view.gets)
          yield row
        end
      end
    end
    
    private
    
    def parse_line line
      return nil unless line
      if /(\{.*\}),?/.match(line.chomp)
        JSON.parse($1)
      end
    end
    
  end
end

Version data entries

6 entries across 6 versions & 2 rubygems

Version	Path
jchris-couchrest-0.9.4	lib/couchrest/helper/streamer.rb
jchris-couchrest-0.9.5	lib/couchrest/helper/streamer.rb
jchris-couchrest-0.9.6	lib/couchrest/helper/streamer.rb
jchris-couchrest-0.9.7	lib/couchrest/helper/streamer.rb
jchris-couchrest-0.9.8	lib/couchrest/helper/streamer.rb
topfunky-couchrest-0.9.4	lib/couchrest/helper/streamer.rb