use our own JsonStream and a created callback in CouchChanges

1 files changed, 1 insertions, 3 deletions

diff --git a/lib/tapicero/couch_stream.rb b/lib/tapicero/couch_stream.rb
index 96c752a..8583010 100644
--- a/lib/tapicero/couch_stream.rb
+++ b/lib/tapicero/couch_stream.rb
@@ -1,5 +1,3 @@
-require 'yajl/http_stream'
-
 module Tapicero
   class CouchStream
     def initialize(database_url)
@@ -9,7 +7,7 @@ module Tapicero
     def get(path, options)
       url = url_for(path, options)
       # puts url
-      Yajl::HttpStream.get(url, :symbolize_keys => true) do |hash|
+      Tapicero::JsonStream.get(url, :symbolize_keys => true) do |hash|
         yield(hash)
       end
     end