Call on_error if a non-hash JSON object is received. Closes tweetstre…

…am#13

lib/tweetstream/client.rb

@@ -194,7 +194,14 @@ def start(path, query_parameters = {}, &block) #:nodoc:
         )
 
         @stream.each_item do |item|
-          hash = TweetStream::Hash.new(@parser.decode(item)) # @parser.parse(item)
+          raw_hash = @parser.decode(item)
+
+          unless raw_hash.is_a?(::Hash)
+            error_proc.call("Unexpected JSON object in stream: #{item}")
+            next
+          end
+
+          hash = TweetStream::Hash.new(raw_hash) # @parser.parse(item)
 
           if hash[:delete] && hash[:delete][:status]
             delete_proc.call(hash[:delete][:status][:id], hash[:delete][:status][:user_id]) if delete_proc.is_a?(Proc)

spec/tweetstream/client_spec.rb

@@ -125,6 +125,13 @@
           track.should == 1234
         end.track('abc')
       end
+
+      it 'should call on_error if a non-hash response is received' do
+        @stream.should_receive(:each_item).and_yield('["favorited"]')
+        @client.on_error do |message|
+          message.should == 'Unexpected JSON object in stream: ["favorited"]'
+        end.track('abc')
+      end
     end
 
     describe '#on_error' do